public class KeyValueFileReaderFactory extends Object
RecordReader
s for reading KeyValue
files.Modifier and Type | Class and Description |
---|---|
static class |
KeyValueFileReaderFactory.Builder
Builder for
KeyValueFileReaderFactory . |
Modifier and Type | Method and Description |
---|---|
static KeyValueFileReaderFactory.Builder |
builder(SchemaManager schemaManager,
long schemaId,
org.apache.flink.table.types.logical.RowType keyType,
org.apache.flink.table.types.logical.RowType valueType,
FileFormat fileFormat,
FileStorePathFactory pathFactory,
KeyValueFieldsExtractor extractor) |
RecordReader<KeyValue> |
createRecordReader(long schemaId,
String fileName,
int level) |
public RecordReader<KeyValue> createRecordReader(long schemaId, String fileName, int level) throws IOException
IOException
public static KeyValueFileReaderFactory.Builder builder(SchemaManager schemaManager, long schemaId, org.apache.flink.table.types.logical.RowType keyType, org.apache.flink.table.types.logical.RowType valueType, FileFormat fileFormat, FileStorePathFactory pathFactory, KeyValueFieldsExtractor extractor)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.