Package org.apache.beam.sdk.fn.stream
Interface PrefetchableIterator<T>
- All Superinterfaces:
Iterator<T>
- All Known Implementing Classes:
DataStreams.DataStreamDecoder
Iterator
that supports prefetching the next set of records.-
Method Summary
Modifier and TypeMethodDescriptionboolean
isReady()
Returnstrue
if and only ifIterator.hasNext()
andIterator.next()
will not require an expensive operation.void
prefetch()
Methods inherited from interface java.util.Iterator
forEachRemaining, hasNext, next, remove
-
Method Details
-
isReady
boolean isReady()Returnstrue
if and only ifIterator.hasNext()
andIterator.next()
will not require an expensive operation. -
prefetch
void prefetch()
-