Class RedisState
java.lang.Object
org.apache.storm.redis.trident.state.RedisState
- All Implemented Interfaces:
State
Implementation of State for single Redis environment.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classRedisState.Factory implements StateFactory for single Redis environment. -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidbeginCommit(Long someLong) voidredis.clients.jedis.JedisgetJedis()Borrows Jedis instance from pool.voidreturnJedis(redis.clients.jedis.Jedis jedis) Returns Jedis instance to pool.
-
Constructor Details
-
RedisState
public RedisState(redis.clients.jedis.JedisPool jedisPool) Constructor.- Parameters:
jedisPool- JedisPool
-
-
Method Details
-
beginCommit
- Specified by:
beginCommitin interfaceState
-
commit
-
getJedis
public redis.clients.jedis.Jedis getJedis()Borrows Jedis instance from pool. Note that you should return borrowed instance to pool when you finish using instance.- Returns:
- Jedis instance
-
returnJedis
public void returnJedis(redis.clients.jedis.Jedis jedis) Returns Jedis instance to pool.- Parameters:
jedis- Jedis instance to return to pool
-