Class RedisClusterMapState<T>
java.lang.Object
org.apache.storm.redis.trident.state.AbstractRedisMapState<T>
org.apache.storm.redis.trident.state.RedisClusterMapState<T>
- Type Parameters:
T
- value's type class
- All Implemented Interfaces:
IBackingMap<T>
IBackingMap implementation for Redis Cluster environment.
- See Also:
-
Nested Class Summary
Modifier and TypeClassDescriptionprotected static class
RedisClusterMapState.Factory provides Redis Cluster environment version of StateFactory. -
Field Summary
Fields inherited from class org.apache.storm.redis.trident.state.AbstractRedisMapState
DEFAULT_SERIALIZERS
-
Constructor Summary
ConstructorDescriptionRedisClusterMapState
(redis.clients.jedis.JedisCluster jedisCluster, Options options, Serializer<T> serializer, KeyFactory keyFactory) Constructor. -
Method Summary
Modifier and TypeMethodDescriptionprotected KeyFactory
Returns KeyFactory which is used for converting state key -> Redis key.protected Serializer
Returns Serializer which is used for serializing tuple value and deserializing Redis value.static StateFactory
nonTransactional
(JedisClusterConfig jedisClusterConfig) Provides StateFactory for non transactional.static StateFactory
nonTransactional
(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for non transactional.static StateFactory
nonTransactional
(JedisClusterConfig jedisClusterConfig, KeyFactory factory) Provides StateFactory for non transactional.static StateFactory
nonTransactional
(JedisClusterConfig jedisClusterConfig, Options<Object> opts) Provides StateFactory for non transactional.static StateFactory
opaque
(JedisClusterConfig jedisClusterConfig) Provides StateFactory for opaque transactional.static StateFactory
opaque
(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for opaque transactional.static StateFactory
opaque
(JedisClusterConfig jedisClusterConfig, KeyFactory factory) Provides StateFactory for opaque transactional.static StateFactory
opaque
(JedisClusterConfig jedisClusterConfig, Options<OpaqueValue> opts) Provides StateFactory for opaque transactional.retrieveValuesFromRedis
(List<String> keys) Retrieves values from Redis that each value is corresponding to each key.static StateFactory
transactional
(JedisClusterConfig jedisClusterConfig) Provides StateFactory for transactional.static StateFactory
transactional
(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for transactional.static StateFactory
transactional
(JedisClusterConfig jedisClusterConfig, KeyFactory factory) Provides StateFactory for transactional.static StateFactory
transactional
(JedisClusterConfig jedisClusterConfig, Options<TransactionalValue> opts) Provides StateFactory for transactional.protected void
updateStatesToRedis
(Map<String, String> keyValues) Updates (key, value) pairs to Redis.Methods inherited from class org.apache.storm.redis.trident.state.AbstractRedisMapState
multiGet, multiPut
-
Constructor Details
-
RedisClusterMapState
public RedisClusterMapState(redis.clients.jedis.JedisCluster jedisCluster, Options options, Serializer<T> serializer, KeyFactory keyFactory) Constructor.- Parameters:
jedisCluster
- JedisClusteroptions
- options of Stateserializer
- SerializerkeyFactory
- KeyFactory
-
-
Method Details
-
opaque
Provides StateFactory for opaque transactional.- Parameters:
jedisClusterConfig
- configuration for JedisCluster- Returns:
- StateFactory
-
opaque
public static StateFactory opaque(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for opaque transactional.- Parameters:
jedisClusterConfig
- configuration for JedisClusterdataTypeDescription
- definition of data type- Returns:
- StateFactory
-
opaque
Provides StateFactory for opaque transactional.- Parameters:
jedisClusterConfig
- configuration for JedisClusterfactory
- key factory- Returns:
- StateFactory
-
opaque
Provides StateFactory for opaque transactional.- Parameters:
jedisClusterConfig
- configuration for JedisClusteropts
- options of State- Returns:
- StateFactory
-
transactional
Provides StateFactory for transactional.- Parameters:
jedisClusterConfig
- configuration for JedisCluster- Returns:
- StateFactory
-
transactional
public static StateFactory transactional(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for transactional.- Parameters:
jedisClusterConfig
- configuration for JedisClusterdataTypeDescription
- definition of data type- Returns:
- StateFactory
-
transactional
Provides StateFactory for transactional.- Parameters:
jedisClusterConfig
- configuration for JedisClusterfactory
- key factory- Returns:
- StateFactory
-
transactional
public static StateFactory transactional(JedisClusterConfig jedisClusterConfig, Options<TransactionalValue> opts) Provides StateFactory for transactional.- Parameters:
jedisClusterConfig
- configuration for JedisClusteropts
- options of State- Returns:
- StateFactory
-
nonTransactional
Provides StateFactory for non transactional.- Parameters:
jedisClusterConfig
- configuration for JedisCluster- Returns:
- StateFactory
-
nonTransactional
public static StateFactory nonTransactional(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for non transactional.- Parameters:
jedisClusterConfig
- configuration for JedisClusterdataTypeDescription
- definition of data type- Returns:
- StateFactory
-
nonTransactional
public static StateFactory nonTransactional(JedisClusterConfig jedisClusterConfig, KeyFactory factory) Provides StateFactory for non transactional.- Parameters:
jedisClusterConfig
- configuration for JedisClusterfactory
- key factory- Returns:
- StateFactory
-
nonTransactional
public static StateFactory nonTransactional(JedisClusterConfig jedisClusterConfig, Options<Object> opts) Provides StateFactory for non transactional.- Parameters:
jedisClusterConfig
- configuration for JedisClusteropts
- options of State- Returns:
- StateFactory
-
getSerializer
Returns Serializer which is used for serializing tuple value and deserializing Redis value.- Specified by:
getSerializer
in classAbstractRedisMapState<T>
- Returns:
- serializer
-
getKeyFactory
Returns KeyFactory which is used for converting state key -> Redis key.- Specified by:
getKeyFactory
in classAbstractRedisMapState<T>
- Returns:
- key factory
-
retrieveValuesFromRedis
Retrieves values from Redis that each value is corresponding to each key.- Specified by:
retrieveValuesFromRedis
in classAbstractRedisMapState<T>
- Parameters:
keys
- keys having state values- Returns:
- values which are corresponding to keys
-
updateStatesToRedis
Updates (key, value) pairs to Redis.- Specified by:
updateStatesToRedis
in classAbstractRedisMapState<T>
- Parameters:
keyValues
- (key, value) pairs
-