public class KeyValueFileReaderFactory extends Object implements FileReaderFactory<KeyValue>
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(FileIO fileIO,
SchemaManager schemaManager,
TableSchema schema,
RowType keyType,
RowType valueType,
FileFormatDiscover formatDiscover,
FileStorePathFactory pathFactory,
KeyValueFieldsExtractor extractor,
CoreOptions options) |
RecordReader<KeyValue> |
createRecordReader(DataFileMeta file) |
RecordReader<KeyValue> |
createRecordReader(long schemaId,
String fileName,
long fileSize,
int level) |
public RecordReader<KeyValue> createRecordReader(DataFileMeta file) throws IOException
createRecordReader
in interface FileReaderFactory<KeyValue>
IOException
public RecordReader<KeyValue> createRecordReader(long schemaId, String fileName, long fileSize, int level) throws IOException
IOException
public static KeyValueFileReaderFactory.Builder builder(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, RowType keyType, RowType valueType, FileFormatDiscover formatDiscover, FileStorePathFactory pathFactory, KeyValueFieldsExtractor extractor, CoreOptions options)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.