Uses of Interface
org.apache.storm.state.Serializer
-
Packages that use Serializer Package Description org.apache.storm.redis.state org.apache.storm.state -
-
Uses of Serializer in org.apache.storm.redis.state
Constructors in org.apache.storm.redis.state with parameters of type Serializer Constructor Description 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, 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. -
Uses of Serializer in org.apache.storm.state
Classes in org.apache.storm.state that implement Serializer Modifier and Type Class 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 Description static Serializer<Optional<byte[]>>
DefaultStateEncoder. INTERNAL_VALUE_SERIALIZER
Methods in org.apache.storm.state that return Serializer Modifier and Type Method Description Serializer<K>
DefaultStateEncoder. getKeySerializer()
Serializer<V>
DefaultStateEncoder. getValueSerializer()
Constructors in org.apache.storm.state with parameters of type Serializer Constructor Description DefaultStateEncoder(Serializer<K> keySerializer, Serializer<V> valueSerializer)
-