Uses of Interface
org.apache.storm.state.Serializer

Packages that use Serializer

Package	Description
org.apache.storm.hbase.state
org.apache.storm.redis.state
org.apache.storm.state

Uses of Serializer in org.apache.storm.hbase.state

Constructors in org.apache.storm.hbase.state with parameters of type Serializer

Constructor and Description
HBaseKeyValueState(HBaseClient hbaseClient, String columnFamily, String namespace, Serializer<K> keySerializer, Serializer<V> valueSerializer) Constructor.
HBaseKeyValueState(HBaseClient hbaseClient, String columnFamily, String namespace, Serializer<K> keySerializer, Serializer<V> valueSerializer) Constructor.
HBaseKeyValueStateIterator(String namespace, byte[] columnFamily, HBaseClient hbaseClient, Iterator<Map.Entry<byte[],byte[]>> pendingPrepareIterator, Iterator<Map.Entry<byte[],byte[]>> pendingCommitIterator, int chunkSize, Serializer<K> keySerializer, Serializer<V> valueSerializer) Constructor.
HBaseKeyValueStateIterator(String namespace, byte[] columnFamily, HBaseClient hbaseClient, Iterator<Map.Entry<byte[],byte[]>> pendingPrepareIterator, Iterator<Map.Entry<byte[],byte[]>> pendingCommitIterator, int chunkSize, Serializer<K> keySerializer, Serializer<V> valueSerializer) Constructor.

Uses of Serializer in org.apache.storm.redis.state

Constructors in org.apache.storm.redis.state with parameters of type Serializer

Constructor and Description
RedisKeyValueState(String namespace, JedisClusterConfig jedisClusterConfig, Serializer<K> keySerializer, Serializer<V> valueSerializer)
RedisKeyValueState(String namespace, JedisClusterConfig jedisClusterConfig, Serializer<K> keySerializer, Serializer<V> valueSerializer)
RedisKeyValueState(String namespace, JedisPoolConfig poolConfig, Serializer<K> keySerializer, Serializer<V> valueSerializer)
RedisKeyValueState(String namespace, JedisPoolConfig poolConfig, Serializer<K> keySerializer, Serializer<V> valueSerializer)
RedisKeyValueState(String namespace, RedisCommandsInstanceContainer container, Serializer<K> keySerializer, Serializer<V> valueSerializer)
RedisKeyValueState(String namespace, RedisCommandsInstanceContainer container, Serializer<K> keySerializer, Serializer<V> valueSerializer)
RedisKeyValueStateIterator(byte[] namespace, RedisCommandsInstanceContainer container, Iterator<Map.Entry<byte[],byte[]>> pendingPrepareIterator, Iterator<Map.Entry<byte[],byte[]>> pendingCommitIterator, int chunkSize, Serializer<K> keySerializer, Serializer<V> valueSerializer) Constructor.
RedisKeyValueStateIterator(byte[] namespace, RedisCommandsInstanceContainer container, Iterator<Map.Entry<byte[],byte[]>> pendingPrepareIterator, Iterator<Map.Entry<byte[],byte[]>> pendingCommitIterator, int chunkSize, Serializer<K> keySerializer, Serializer<V> valueSerializer) Constructor.

Uses of Serializer in org.apache.storm.state

Classes in org.apache.storm.state that implement Serializer

Modifier and Type	Class and Description
class	DefaultStateSerializer<T> A default implementation that uses Kryo to serialize and de-serialize the state.

Fields in org.apache.storm.state declared as Serializer

Modifier and Type	Field and Description
static Serializer<Optional<byte[]>>	DefaultStateEncoder.INTERNAL_VALUE_SERIALIZER

Methods in org.apache.storm.state that return Serializer

Modifier and Type	Method and Description
Serializer<K>	DefaultStateEncoder.getKeySerializer()
Serializer<V>	DefaultStateEncoder.getValueSerializer()

Constructors in org.apache.storm.state with parameters of type Serializer

Constructor and Description
DefaultStateEncoder(Serializer<K> keySerializer, Serializer<V> valueSerializer)
DefaultStateEncoder(Serializer<K> keySerializer, Serializer<V> valueSerializer)