org.apache.storm.redis.trident.state

Class RedisClusterStateUpdater

java.lang.Object

org.apache.storm.trident.operation.BaseOperation

org.apache.storm.trident.state.BaseStateUpdater<T>

org.apache.storm.redis.trident.state.AbstractRedisStateUpdater<RedisClusterState>

org.apache.storm.redis.trident.state.RedisClusterStateUpdater

All Implemented Interfaces:

Serializable, Operation, StateUpdater<RedisClusterState>

public class RedisClusterStateUpdater
extends AbstractRedisStateUpdater<RedisClusterState>

BaseStateUpdater implementation for Redis Cluster environment.

See Also:

AbstractRedisStateUpdater, Serialized Form

Field Summary

Fields inherited from class org.apache.storm.redis.trident.state.AbstractRedisStateUpdater

additionalKey, dataType, expireIntervalSec

Constructor Summary

Constructors

Constructor and Description
RedisClusterStateUpdater(RedisStoreMapper storeMapper) Constructor

Method Summary

Modifier and Type	Method and Description
protected void	updateStatesToRedis(RedisClusterState redisClusterState, Map<String,String> keyToValue) Updates (key, value) pairs to Redis.
RedisClusterStateUpdater	withExpire(int expireIntervalSec) Sets expire (time to live) if needed.

Methods inherited from class org.apache.storm.redis.trident.state.AbstractRedisStateUpdater

setExpireInterval, updateState

Methods inherited from class org.apache.storm.trident.operation.BaseOperation

cleanup, prepare

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.storm.trident.operation.Operation

cleanup, prepare

Constructor Detail

RedisClusterStateUpdater

public RedisClusterStateUpdater(RedisStoreMapper storeMapper)

Constructor

Parameters:

storeMapper - mapper for storing

Method Detail

withExpire

public RedisClusterStateUpdater withExpire(int expireIntervalSec)

Sets expire (time to live) if needed.

Parameters:

expireIntervalSec - time to live in seconds

Returns:

RedisClusterStateUpdater itself

updateStatesToRedis

protected void updateStatesToRedis(RedisClusterState redisClusterState,
                                   Map<String,String> keyToValue)

Updates (key, value) pairs to Redis.

Specified by:

updateStatesToRedis in class AbstractRedisStateUpdater<RedisClusterState>

Parameters:

redisClusterState - State for handling query

keyToValue - (key, value) pairs