public class EmptyRecordReader<T> extends Object implements RecordReader<T>
RecordReader.RecordReader.RecordIterator<T>| Constructor and Description |
|---|
EmptyRecordReader() |
| 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, waitfilter, forEachRemaining, forEachRemainingWithPosition, toCloseableIterator, transform@Nullable public RecordReader.RecordIterator<T> readBatch() throws IOException
RecordReaderThe 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>IOExceptionpublic void close()
throws IOException
RecordReaderclose in interface Closeableclose in interface AutoCloseableclose in interface RecordReader<T>IOExceptionCopyright © 2023–2024 The Apache Software Foundation. All rights reserved.