public class KeyValueDataFileRecordReader extends Object implements RecordReader<KeyValue>
RecordReader
for reading KeyValue
data files.RecordReader.RecordIterator<T>
Constructor and Description |
---|
KeyValueDataFileRecordReader(RecordReader<InternalRow> reader,
RowType keyType,
RowType valueType,
int level) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the reader and should release all resources.
|
RecordReader.RecordIterator<KeyValue> |
readBatch()
Reads one batch.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
filter, forEachRemaining, forEachRemainingWithPosition, toCloseableIterator, transform
public KeyValueDataFileRecordReader(RecordReader<InternalRow> reader, RowType keyType, RowType valueType, int level)
@Nullable public RecordReader.RecordIterator<KeyValue> 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<KeyValue>
IOException
public void close() throws IOException
RecordReader
close
in interface Closeable
close
in interface AutoCloseable
close
in interface RecordReader<KeyValue>
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.