org.apache.storm.redis.trident.state

Class RedisState

java.lang.Object

org.apache.storm.redis.trident.state.RedisState

All Implemented Interfaces:

State

public class RedisState
extends Object
implements State

Implementation of State for single Redis environment.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RedisState.Factory RedisState.Factory implements StateFactory for single Redis environment.

Constructor Summary

Constructors

Constructor and Description
RedisState(redis.clients.jedis.JedisPool jedisPool) Constructor

Method Summary

Modifier and Type	Method and Description
void	beginCommit(Long aLong)
void	commit(Long aLong)
redis.clients.jedis.Jedis	getJedis() Borrows Jedis instance from pool.
void	returnJedis(redis.clients.jedis.Jedis jedis) Returns Jedis instance to pool.

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisState

public RedisState(redis.clients.jedis.JedisPool jedisPool)

Constructor

Parameters:

jedisPool - JedisPool

Method Detail

beginCommit

public void beginCommit(Long aLong)

Specified by:

beginCommit in interface State

commit

public void commit(Long aLong)

Specified by:

commit in interface State

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