public class IteratorRecordReader<T> extends Object implements RecordReader<T>
Iterator
as an RecordReader
.RecordReader.RecordIterator<T>
Constructor and Description |
---|
IteratorRecordReader(Iterator<T> iterator) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the reader and should release all resources.
|
RecordReader.RecordIterator<T> |
readBatch()
Reads one batch.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
filter, forEachRemaining, forEachRemainingWithPosition, toCloseableIterator, transform
@Nullable public RecordReader.RecordIterator<T> readBatch() throws IOException
RecordReader
The returned iterator object and any contained objects may be held onto by the source for some time, so it should not be immediately reused by the reader.
readBatch
in interface RecordReader<T>
IOException
public void close() throws IOException
RecordReader
close
in interface Closeable
close
in interface AutoCloseable
close
in interface RecordReader<T>
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.