Class RedisStateQuerier
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<RedisState>
org.apache.storm.redis.trident.state.RedisStateQuerier
- All Implemented Interfaces:
Serializable,EachOperation,Operation,QueryFunction<RedisState,List<Values>>
BaseQueryFunction implementation for single Redis environment.
- See Also:
-
Field Summary
Fields inherited from class org.apache.storm.redis.trident.state.AbstractRedisStateQuerier
additionalKey, dataType -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionretrieveValuesFromRedis(RedisState 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.AbstractRedisStateQuerier
batchRetrieve, executeMethods inherited from class org.apache.storm.trident.operation.BaseOperation
cleanup, prepare
-
Constructor Details
-
RedisStateQuerier
Constructor.- Parameters:
lookupMapper- mapper for querying
-
-
Method Details
-
retrieveValuesFromRedis
Retrieves values from Redis that each value is corresponding to each key.- Specified by:
retrieveValuesFromRedisin classAbstractRedisStateQuerier<RedisState>- Parameters:
state- State for handling querykeys- keys having state values- Returns:
- values which are corresponding to keys
-