Class RedisKeyValueStateIterator<K,V>

java.lang.Object
org.apache.storm.state.BaseStateIterator<K,V,byte[],byte[]>
org.apache.storm.state.BaseBinaryStateIterator<K,V>
org.apache.storm.redis.state.RedisKeyValueStateIterator<K,V>
All Implemented Interfaces:
Iterator<Map.Entry<K,V>>

public class RedisKeyValueStateIterator<K,V> extends BaseBinaryStateIterator<K,V>
An iterator over RedisKeyValueState.
  • Constructor Details

    • RedisKeyValueStateIterator

      public 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.
      Parameters:
      namespace - The namespace of State
      container - The instance of RedisCommandsInstanceContainer
      pendingPrepareIterator - The iterator of pendingPrepare
      pendingCommitIterator - The iterator of pendingCommit
      chunkSize - The size of chunk to get entries from Redis
      keySerializer - The serializer of key
      valueSerializer - The serializer of value
  • Method Details