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 Summary

Modifier and Type	Method and Description
void	close()
K	peekNextKey() Peek at the next key without advancing the iterator

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext, next, remove

Method Detail

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