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 SummaryNested ClassesModifier and TypeClassDescriptionprotected static classRedisClusterMapState.Factory provides Redis Cluster environment version of StateFactory.
- 
Field SummaryFields inherited from class org.apache.storm.redis.trident.state.AbstractRedisMapStateDEFAULT_SERIALIZERS
- 
Constructor SummaryConstructorsConstructorDescriptionRedisClusterMapState(redis.clients.jedis.JedisCluster jedisCluster, Options options, Serializer<T> serializer, KeyFactory keyFactory) Constructor.
- 
Method SummaryModifier and TypeMethodDescriptionprotected KeyFactoryReturns KeyFactory which is used for converting state key -> Redis key.protected SerializerReturns Serializer which is used for serializing tuple value and deserializing Redis value.static StateFactorynonTransactional(JedisClusterConfig jedisClusterConfig) Provides StateFactory for non transactional.static StateFactorynonTransactional(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for non transactional.static StateFactorynonTransactional(JedisClusterConfig jedisClusterConfig, KeyFactory factory) Provides StateFactory for non transactional.static StateFactorynonTransactional(JedisClusterConfig jedisClusterConfig, Options<Object> opts) Provides StateFactory for non transactional.static StateFactoryopaque(JedisClusterConfig jedisClusterConfig) Provides StateFactory for opaque transactional.static StateFactoryopaque(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for opaque transactional.static StateFactoryopaque(JedisClusterConfig jedisClusterConfig, KeyFactory factory) Provides StateFactory for opaque transactional.static StateFactoryopaque(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 StateFactorytransactional(JedisClusterConfig jedisClusterConfig) Provides StateFactory for transactional.static StateFactorytransactional(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for transactional.static StateFactorytransactional(JedisClusterConfig jedisClusterConfig, KeyFactory factory) Provides StateFactory for transactional.static StateFactorytransactional(JedisClusterConfig jedisClusterConfig, Options<TransactionalValue> opts) Provides StateFactory for transactional.protected voidupdateStatesToRedis(Map<String, String> keyValues) Updates (key, value) pairs to Redis.Methods inherited from class org.apache.storm.redis.trident.state.AbstractRedisMapStatemultiGet, multiPut
- 
Constructor Details- 
RedisClusterMapStatepublic RedisClusterMapState(redis.clients.jedis.JedisCluster jedisCluster, Options options, Serializer<T> serializer, KeyFactory keyFactory) Constructor.- Parameters:
- jedisCluster- JedisCluster
- options- options of State
- serializer- Serializer
- keyFactory- KeyFactory
 
 
- 
- 
Method Details- 
opaqueProvides StateFactory for opaque transactional.- Parameters:
- jedisClusterConfig- configuration for JedisCluster
- Returns:
- StateFactory
 
- 
opaquepublic static StateFactory opaque(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for opaque transactional.- Parameters:
- jedisClusterConfig- configuration for JedisCluster
- dataTypeDescription- definition of data type
- Returns:
- StateFactory
 
- 
opaqueProvides StateFactory for opaque transactional.- Parameters:
- jedisClusterConfig- configuration for JedisCluster
- factory- key factory
- Returns:
- StateFactory
 
- 
opaqueProvides StateFactory for opaque transactional.- Parameters:
- jedisClusterConfig- configuration for JedisCluster
- opts- options of State
- Returns:
- StateFactory
 
- 
transactionalProvides StateFactory for transactional.- Parameters:
- jedisClusterConfig- configuration for JedisCluster
- Returns:
- StateFactory
 
- 
transactionalpublic static StateFactory transactional(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for transactional.- Parameters:
- jedisClusterConfig- configuration for JedisCluster
- dataTypeDescription- definition of data type
- Returns:
- StateFactory
 
- 
transactionalProvides StateFactory for transactional.- Parameters:
- jedisClusterConfig- configuration for JedisCluster
- factory- key factory
- Returns:
- StateFactory
 
- 
transactionalpublic static StateFactory transactional(JedisClusterConfig jedisClusterConfig, Options<TransactionalValue> opts) Provides StateFactory for transactional.- Parameters:
- jedisClusterConfig- configuration for JedisCluster
- opts- options of State
- Returns:
- StateFactory
 
- 
nonTransactionalProvides StateFactory for non transactional.- Parameters:
- jedisClusterConfig- configuration for JedisCluster
- Returns:
- StateFactory
 
- 
nonTransactionalpublic static StateFactory nonTransactional(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for non transactional.- Parameters:
- jedisClusterConfig- configuration for JedisCluster
- dataTypeDescription- definition of data type
- Returns:
- StateFactory
 
- 
nonTransactionalpublic static StateFactory nonTransactional(JedisClusterConfig jedisClusterConfig, KeyFactory factory) Provides StateFactory for non transactional.- Parameters:
- jedisClusterConfig- configuration for JedisCluster
- factory- key factory
- Returns:
- StateFactory
 
- 
nonTransactionalpublic static StateFactory nonTransactional(JedisClusterConfig jedisClusterConfig, Options<Object> opts) Provides StateFactory for non transactional.- Parameters:
- jedisClusterConfig- configuration for JedisCluster
- opts- options of State
- Returns:
- StateFactory
 
- 
getSerializerReturns Serializer which is used for serializing tuple value and deserializing Redis value.- Specified by:
- getSerializerin class- AbstractRedisMapState<T>
- Returns:
- serializer
 
- 
getKeyFactoryReturns KeyFactory which is used for converting state key -> Redis key.- Specified by:
- getKeyFactoryin class- AbstractRedisMapState<T>
- Returns:
- key factory
 
- 
retrieveValuesFromRedisRetrieves values from Redis that each value is corresponding to each key.- Specified by:
- retrieveValuesFromRedisin class- AbstractRedisMapState<T>
- Parameters:
- keys- keys having state values
- Returns:
- values which are corresponding to keys
 
- 
updateStatesToRedisUpdates (key, value) pairs to Redis.- Specified by:
- updateStatesToRedisin class- AbstractRedisMapState<T>
- Parameters:
- keyValues- (key, value) pairs
 
 
-