Package org.apache.kafka.streams.state
Interface WindowStoreIterator<V>
- Type Parameters:
V- Type of values
- All Superinterfaces:
AutoCloseable,Closeable,Iterator<KeyValue<Long,,V>> KeyValueIterator<Long,V>
Iterator interface of
KeyValue with key typed Long used for WindowStore.fetch(Object, long, long)
and WindowStore.fetch(Object, Instant, Instant)
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.-
Method Summary
Methods inherited from interface java.util.Iterator
forEachRemaining, hasNext, next, removeMethods inherited from interface org.apache.kafka.streams.state.KeyValueIterator
peekNextKey
-
Method Details
-
close
void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceKeyValueIterator<Long,V>
-