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>
public interface WindowStoreIterator<V> extends KeyValueIterator<Long,V>, Closeable
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
Modifier and Type Method Description voidclose()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>
-