Uses of Interface
org.apache.storm.state.Serializer
Packages that use Serializer
-
Uses of Serializer in org.apache.storm.redis.state
Constructors in org.apache.storm.redis.state with parameters of type SerializerModifierConstructorDescriptionRedisKeyValueState
(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 SerializerModifier and TypeClassDescriptionclass
A default implementation that uses Kryo to serialize and de-serialize the state.Fields in org.apache.storm.state declared as SerializerModifier and TypeFieldDescriptionstatic final Serializer<Optional<byte[]>>
DefaultStateEncoder.INTERNAL_VALUE_SERIALIZER
Methods in org.apache.storm.state that return SerializerModifier and TypeMethodDescriptionDefaultStateEncoder.getKeySerializer()
DefaultStateEncoder.getValueSerializer()
Constructors in org.apache.storm.state with parameters of type SerializerModifierConstructorDescriptionDefaultStateEncoder
(Serializer<K> keySerializer, Serializer<V> valueSerializer)