Class RedisClusterState
java.lang.Object
org.apache.storm.redis.trident.state.RedisClusterState
- All Implemented Interfaces:
- State
Implementation of State for Redis Cluster environment.
- 
Nested Class SummaryNested ClassesModifier and TypeClassDescriptionstatic classRedisClusterState.Factory implements StateFactory for Redis Cluster environment.
- 
Constructor SummaryConstructorsConstructorDescriptionRedisClusterState(redis.clients.jedis.JedisCluster jedisCluster) Constructor.
- 
Method SummaryModifier and TypeMethodDescriptionvoidbeginCommit(Long someLong) voidredis.clients.jedis.JedisClusterBorrows JedisCluster instance.voidreturnJedisCluster(redis.clients.jedis.JedisCluster jedisCluster) Returns JedisCluster instance to pool.
- 
Constructor Details- 
RedisClusterStatepublic RedisClusterState(redis.clients.jedis.JedisCluster jedisCluster) Constructor.- Parameters:
- jedisCluster- JedisCluster
 
 
- 
- 
Method Details- 
beginCommit- Specified by:
- beginCommitin interface- State
 
- 
commit
- 
getJedisClusterpublic redis.clients.jedis.JedisCluster getJedisCluster()Borrows JedisCluster instance.Note that you should return borrowed instance when you finish using instance. - Returns:
- JedisCluster instance
 
- 
returnJedisClusterpublic void returnJedisCluster(redis.clients.jedis.JedisCluster jedisCluster) Returns JedisCluster instance to pool.- Parameters:
- jedisCluster- JedisCluster instance to return to pool
 
 
-