public abstract class AbstractRedisMapState<T> extends Object implements IBackingMap<T>
AbstractRedisMapState is base class of any RedisMapState, which implements IBackingMap.
Derived classes should provideModifier and Type | Field and Description |
---|---|
static EnumMap<StateType,Serializer> |
DEFAULT_SERIALIZERS |
Constructor and Description |
---|
AbstractRedisMapState() |
Modifier and Type | Method and Description |
---|---|
protected abstract KeyFactory |
getKeyFactory()
Returns KeyFactory which is used for converting state key -> Redis key.
|
protected abstract Serializer |
getSerializer()
Returns Serializer which is used for serializing tuple value and deserializing Redis value.
|
List<T> |
multiGet(List<List<Object>> keys) |
void |
multiPut(List<List<Object>> keys,
List<T> vals) |
protected abstract List<String> |
retrieveValuesFromRedis(List<String> keys)
Retrieves values from Redis that each value is corresponding to each key.
|
protected abstract void |
updateStatesToRedis(Map<String,String> keyValues)
Updates (key, value) pairs to Redis.
|
public static final EnumMap<StateType,Serializer> DEFAULT_SERIALIZERS
public List<T> multiGet(List<List<Object>> keys)
multiGet
in interface IBackingMap<T>
public void multiPut(List<List<Object>> keys, List<T> vals)
multiPut
in interface IBackingMap<T>
protected abstract Serializer getSerializer()
Returns Serializer which is used for serializing tuple value and deserializing Redis value.
protected abstract KeyFactory getKeyFactory()
Returns KeyFactory which is used for converting state key -> Redis key.
protected abstract List<String> retrieveValuesFromRedis(List<String> keys)
Retrieves values from Redis that each value is corresponding to each key.
keys
- keys having state valuesCopyright © 2022 The Apache Software Foundation. All rights reserved.