public class RecordReaderIterator<T> extends Object implements CloseableIterator<T>
RecordReader
as an CloseableIterator
.CloseableIterator.IteratorAdapter<E>
EMPTY_INSTANCE
Constructor and Description |
---|
RecordReaderIterator(RecordReader<T> reader) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
hasNext()
IMPORTANT: Before calling this, make sure that the previous returned key-value is not
used any more!
|
T |
next() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
adapterForIterator, adapterForIterator, empty, flatten, fromList, ofElement, ofElements
forEachRemaining, remove
public RecordReaderIterator(RecordReader<T> reader)
public boolean hasNext()
public void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.