Package | Description |
---|---|
org.apache.storm.hbase.trident.state | |
org.apache.storm.redis.trident.state |
Modifier and Type | Field and Description |
---|---|
Serializer<T> |
HBaseMapState.Options.serializer |
Modifier and Type | Field and Description |
---|---|
Serializer<T> |
Options.serializer |
Modifier and Type | Field and Description |
---|---|
static EnumMap<StateType,Serializer> |
AbstractRedisMapState.DEFAULT_SERIALIZERS |
Modifier and Type | Method and Description |
---|---|
protected Serializer |
RedisMapState.getSerializer()
Returns Serializer which is used for serializing tuple value and deserializing Redis value.
|
protected Serializer |
RedisClusterMapState.getSerializer()
Returns Serializer which is used for serializing tuple value and deserializing Redis value.
|
protected abstract Serializer |
AbstractRedisMapState.getSerializer()
Returns Serializer which is used for serializing tuple value and deserializing Redis value.
|
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.