Class RedisClusterStateQuerier
java.lang.Object
org.apache.storm.trident.operation.BaseOperation
org.apache.storm.trident.state.BaseQueryFunction<T,List<Values>>
 
org.apache.storm.redis.trident.state.AbstractRedisStateQuerier<RedisClusterState>
org.apache.storm.redis.trident.state.RedisClusterStateQuerier
- All Implemented Interfaces:
- Serializable,- EachOperation,- Operation,- QueryFunction<RedisClusterState,- List<Values>> 
BaseQueryFunction implementation for Redis Cluster environment.
- See Also:
- 
Field SummaryFields inherited from class org.apache.storm.redis.trident.state.AbstractRedisStateQuerieradditionalKey, dataType
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionretrieveValuesFromRedis(RedisClusterState state, List<String> keys) Retrieves values from Redis that each value is corresponding to each key.Methods inherited from class org.apache.storm.redis.trident.state.AbstractRedisStateQuerierbatchRetrieve, executeMethods inherited from class org.apache.storm.trident.operation.BaseOperationcleanup, prepare
- 
Constructor Details- 
RedisClusterStateQuerierConstructor.- Parameters:
- lookupMapper- mapper for querying
 
 
- 
- 
Method Details- 
retrieveValuesFromRedisRetrieves values from Redis that each value is corresponding to each key.- Specified by:
- retrieveValuesFromRedisin class- AbstractRedisStateQuerier<RedisClusterState>
- Parameters:
- state- State for handling query
- keys- keys having state values
- Returns:
- values which are corresponding to keys
 
 
-