Class RedisStateUpdater
java.lang.Object
org.apache.storm.trident.operation.BaseOperation
org.apache.storm.trident.state.BaseStateUpdater<T>
org.apache.storm.redis.trident.state.AbstractRedisStateUpdater<RedisState>
org.apache.storm.redis.trident.state.RedisStateUpdater
- All Implemented Interfaces:
- Serializable,- Operation,- StateUpdater<RedisState>
BaseStateUpdater implementation for single Redis environment.
- See Also:
- 
Field SummaryFields inherited from class org.apache.storm.redis.trident.state.AbstractRedisStateUpdateradditionalKey, dataType, expireIntervalSec
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionprotected voidupdateStatesToRedis(RedisState redisState, Map<String, String> keyToValue) Updates (key, value) pairs to Redis.withExpire(int expireIntervalSec) Sets expire (time to live) if needed.Methods inherited from class org.apache.storm.redis.trident.state.AbstractRedisStateUpdatersetExpireInterval, updateStateMethods inherited from class org.apache.storm.trident.operation.BaseOperationcleanup, prepare
- 
Constructor Details- 
RedisStateUpdaterConstructor.- Parameters:
- storeMapper- mapper for storing
 
 
- 
- 
Method Details- 
withExpireSets expire (time to live) if needed.- Parameters:
- expireIntervalSec- time to live in seconds
- Returns:
- RedisStateUpdater itself
 
- 
updateStatesToRedisUpdates (key, value) pairs to Redis.- Specified by:
- updateStatesToRedisin class- AbstractRedisStateUpdater<RedisState>
- Parameters:
- redisState- State for handling query
- keyToValue- (key, value) pairs
 
 
-