Uses of Interface
org.apache.storm.state.Serializer
-
Uses of Serializer in org.apache.storm.redis.state
ModifierConstructorDescriptionRedisKeyValueState
(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
Modifier and TypeClassDescriptionclass
A default implementation that uses Kryo to serialize and de-serialize the state.Modifier and TypeFieldDescriptionstatic final Serializer<Optional<byte[]>>
DefaultStateEncoder.INTERNAL_VALUE_SERIALIZER
Modifier and TypeMethodDescriptionDefaultStateEncoder.getKeySerializer()
DefaultStateEncoder.getValueSerializer()
ModifierConstructorDescriptionDefaultStateEncoder
(Serializer<K> keySerializer, Serializer<V> valueSerializer)