Package org.apache.kafka.streams.state

Interface KeyValueIterator<K,​V>

Type Parameters:
K - Type of keys
V - Type of values
All Superinterfaces:
AutoCloseable, Closeable, Iterator<KeyValue<K,​V>>
All Known Subinterfaces:
WindowStoreIterator<V>
public interface KeyValueIterator<K,​V>
extends Iterator<KeyValue<K,​V>>, Closeable
Iterator interface of KeyValue.

Users must call its close method explicitly upon completeness to release resources, or use try-with-resources statement (available since JDK7) for this Closeable class. Note that remove() is not supported.

  • Method Details

    • close

      void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable

    • peekNextKey

      K peekNextKey()
      Peek at the next key without advancing the iterator
      Returns:
      the key of the next value that would be returned from the next call to next