public interface RecordReader<T> extends Closeable
Modifier and Type | Interface and Description |
---|---|
static interface |
RecordReader.RecordIterator<T>
An internal iterator interface which presents a more restrictive API than
Iterator . |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the reader and should release all resources.
|
RecordReader.RecordIterator<T> |
readBatch()
Reads one batch.
|
@Nullable RecordReader.RecordIterator<T> readBatch() throws IOException
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.
IOException
void close() throws IOException
close
in interface AutoCloseable
close
in interface Closeable
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.