Package | Description |
---|---|
org.apache.storm.redis.trident.state |
Modifier and Type | Class and Description |
---|---|
static class |
KeyFactory.DefaultKeyFactory
Default Key Factory
|
Modifier and Type | Field and Description |
---|---|
KeyFactory |
Options.keyFactory |
Modifier and Type | Method and Description |
---|---|
protected KeyFactory |
RedisMapState.getKeyFactory()
Returns KeyFactory which is used for converting state key -> Redis key.
|
protected KeyFactory |
RedisClusterMapState.getKeyFactory()
Returns KeyFactory which is used for converting state key -> Redis key.
|
protected abstract KeyFactory |
AbstractRedisMapState.getKeyFactory()
Returns KeyFactory which is used for converting state key -> Redis key.
|
Modifier and Type | Method and Description |
---|---|
static StateFactory |
RedisClusterMapState.nonTransactional(JedisClusterConfig jedisClusterConfig,
KeyFactory factory)
Provides StateFactory for non transactional.
|
static StateFactory |
RedisMapState.nonTransactional(JedisPoolConfig jedisPoolConfig,
KeyFactory factory)
Provides StateFactory for non transactional.
|
static StateFactory |
RedisClusterMapState.opaque(JedisClusterConfig jedisClusterConfig,
KeyFactory factory)
Provides StateFactory for opaque transactional.
|
static StateFactory |
RedisMapState.opaque(JedisPoolConfig jedisPoolConfig,
KeyFactory factory)
Provides StateFactory for opaque transactional.
|
static StateFactory |
RedisClusterMapState.transactional(JedisClusterConfig jedisClusterConfig,
KeyFactory factory)
Provides StateFactory for transactional.
|
static StateFactory |
RedisMapState.transactional(JedisPoolConfig jedisPoolConfig,
KeyFactory factory)
Provides StateFactory for transactional.
|
Constructor and Description |
---|
RedisClusterMapState(redis.clients.jedis.JedisCluster jedisCluster,
Options options,
Serializer<T> serializer,
KeyFactory keyFactory)
Constructor
|
RedisMapState(redis.clients.jedis.JedisPool jedisPool,
Options options,
Serializer<T> serializer,
KeyFactory keyFactory)
Constructor
|
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.