public abstract class KeyValueTableRead extends Object implements TableRead
KeyValueFileStoreRead
to provide reading of RowData
.Modifier and Type | Field and Description |
---|---|
protected KeyValueFileStoreRead |
read |
Modifier | Constructor and Description |
---|---|
protected |
KeyValueTableRead(KeyValueFileStoreRead read) |
Modifier and Type | Method and Description |
---|---|
RecordReader<org.apache.flink.table.data.RowData> |
createReader(Split split) |
protected abstract RecordReader.RecordIterator<org.apache.flink.table.data.RowData> |
rowDataRecordIteratorFromKv(RecordReader.RecordIterator<KeyValue> kvRecordIterator) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createReader, withFilter, withFilter, withProjection, withProjection
protected final KeyValueFileStoreRead read
protected KeyValueTableRead(KeyValueFileStoreRead read)
public RecordReader<org.apache.flink.table.data.RowData> createReader(Split split) throws IOException
createReader
in interface TableRead
IOException
protected abstract RecordReader.RecordIterator<org.apache.flink.table.data.RowData> rowDataRecordIteratorFromKv(RecordReader.RecordIterator<KeyValue> kvRecordIterator)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.