Class RedisClusterState
- java.lang.Object
-
- org.apache.storm.redis.trident.state.RedisClusterState
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
RedisClusterState.Factory
RedisClusterState.Factory implements StateFactory for Redis Cluster environment.
-
Constructor Summary
Constructors Constructor Description RedisClusterState(redis.clients.jedis.JedisCluster jedisCluster)
Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
beginCommit(Long someLong)
void
commit(Long someLong)
redis.clients.jedis.JedisCluster
getJedisCluster()
Borrows JedisCluster instance.void
returnJedisCluster(redis.clients.jedis.JedisCluster jedisCluster)
Returns JedisCluster instance to pool.
-
-
-
Method Detail
-
beginCommit
public void beginCommit(Long someLong)
- Specified by:
beginCommit
in interfaceState
-
getJedisCluster
public redis.clients.jedis.JedisCluster getJedisCluster()
Borrows JedisCluster instance.Note that you should return borrowed instance when you finish using instance.
- Returns:
- JedisCluster instance
-
returnJedisCluster
public void returnJedisCluster(redis.clients.jedis.JedisCluster jedisCluster)
Returns JedisCluster instance to pool.- Parameters:
jedisCluster
- JedisCluster instance to return to pool
-
-