Package org.apache.storm.redis.trident.state

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>
public class RedisClusterMapState<T> extends AbstractRedisMapState<T>
IBackingMap implementation for Redis Cluster environment.
See Also:

  • Constructor Details

    • RedisClusterMapState

      public 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

    • opaque

      public static StateFactory opaque(JedisClusterConfig jedisClusterConfig)
      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 JedisCluster
      dataTypeDescription - definition of data type
      Returns:
      StateFactory

    • opaque

      public static StateFactory opaque(JedisClusterConfig jedisClusterConfig, KeyFactory factory)
      Provides StateFactory for opaque transactional.
      Parameters:
      jedisClusterConfig - configuration for JedisCluster
      factory - key factory
      Returns:
      StateFactory

    • opaque

      public static StateFactory opaque(JedisClusterConfig jedisClusterConfig, Options<OpaqueValue> opts)
      Provides StateFactory for opaque transactional.
      Parameters:
      jedisClusterConfig - configuration for JedisCluster
      opts - options of State
      Returns:
      StateFactory

    • transactional

      public static StateFactory transactional(JedisClusterConfig jedisClusterConfig)
      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 JedisCluster
      dataTypeDescription - definition of data type
      Returns:
      StateFactory

    • transactional

      public static StateFactory transactional(JedisClusterConfig jedisClusterConfig, KeyFactory factory)
      Provides StateFactory for transactional.
      Parameters:
      jedisClusterConfig - configuration for JedisCluster
      factory - key factory
      Returns:
      StateFactory

    • transactional

      public static StateFactory transactional(JedisClusterConfig jedisClusterConfig, Options<TransactionalValue> opts)
      Provides StateFactory for transactional.
      Parameters:
      jedisClusterConfig - configuration for JedisCluster
      opts - options of State
      Returns:
      StateFactory

    • nonTransactional

      public static StateFactory nonTransactional(JedisClusterConfig jedisClusterConfig)
      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 JedisCluster
      dataTypeDescription - definition of data type
      Returns:
      StateFactory

    • nonTransactional

      public static StateFactory nonTransactional(JedisClusterConfig jedisClusterConfig, KeyFactory factory)
      Provides StateFactory for non transactional.
      Parameters:
      jedisClusterConfig - configuration for JedisCluster
      factory - key factory
      Returns:
      StateFactory

    • nonTransactional

      public static StateFactory nonTransactional(JedisClusterConfig jedisClusterConfig, Options<Object> opts)
      Provides StateFactory for non transactional.
      Parameters:
      jedisClusterConfig - configuration for JedisCluster
      opts - options of State
      Returns:
      StateFactory

    • getSerializer

      protected Serializer getSerializer()
      Returns Serializer which is used for serializing tuple value and deserializing Redis value.
      Specified by:
      getSerializer in class AbstractRedisMapState<T>
      Returns:
      serializer

    • getKeyFactory

      protected KeyFactory getKeyFactory()
      Returns KeyFactory which is used for converting state key -> Redis key.
      Specified by:
      getKeyFactory in class AbstractRedisMapState<T>
      Returns:
      key factory

    • retrieveValuesFromRedis

      protected List<String> retrieveValuesFromRedis(List<String> keys)
      Retrieves values from Redis that each value is corresponding to each key.
      Specified by:
      retrieveValuesFromRedis in class AbstractRedisMapState<T>
      Parameters:
      keys - keys having state values
      Returns:
      values which are corresponding to keys

    • updateStatesToRedis

      protected void updateStatesToRedis(Map<String,String> keyValues)
      Updates (key, value) pairs to Redis.
      Specified by:
      updateStatesToRedis in class AbstractRedisMapState<T>
      Parameters:
      keyValues - (key, value) pairs