public class KeyValueFileStoreRead extends Object implements FileStoreRead<KeyValue>
FileStoreRead
implementation for KeyValueFileStore
.Constructor and Description |
---|
KeyValueFileStoreRead(SchemaManager schemaManager,
long schemaId,
org.apache.flink.table.types.logical.RowType keyType,
org.apache.flink.table.types.logical.RowType valueType,
Comparator<org.apache.flink.table.data.RowData> keyComparator,
MergeFunctionFactory<KeyValue> mfFactory,
FileFormat fileFormat,
FileStorePathFactory pathFactory,
KeyValueFieldsExtractor extractor) |
Modifier and Type | Method and Description |
---|---|
RecordReader<KeyValue> |
createReader(DataSplit split)
Create a
RecordReader from split. |
FileStoreRead<KeyValue> |
withFilter(Predicate predicate) |
KeyValueFileStoreRead |
withKeyProjection(int[][] projectedFields) |
KeyValueFileStoreRead |
withValueProjection(int[][] projectedFields) |
public KeyValueFileStoreRead(SchemaManager schemaManager, long schemaId, org.apache.flink.table.types.logical.RowType keyType, org.apache.flink.table.types.logical.RowType valueType, Comparator<org.apache.flink.table.data.RowData> keyComparator, MergeFunctionFactory<KeyValue> mfFactory, FileFormat fileFormat, FileStorePathFactory pathFactory, KeyValueFieldsExtractor extractor)
public KeyValueFileStoreRead withKeyProjection(int[][] projectedFields)
public KeyValueFileStoreRead withValueProjection(int[][] projectedFields)
public FileStoreRead<KeyValue> withFilter(Predicate predicate)
withFilter
in interface FileStoreRead<KeyValue>
public RecordReader<KeyValue> createReader(DataSplit split) throws IOException
FileStoreRead
RecordReader
from split.createReader
in interface FileStoreRead<KeyValue>
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.