org.apache.paimon.io

Class KeyValueFileReaderFactory

java.lang.Object

org.apache.paimon.io.KeyValueFileReaderFactory

All Implemented Interfaces:

FileReaderFactory<KeyValue>

public class KeyValueFileReaderFactory
extends Object
implements FileReaderFactory<KeyValue>

Factory to create RecordReaders for reading KeyValue files.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KeyValueFileReaderFactory.Builder Builder for KeyValueFileReaderFactory.

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createRecordReader

public RecordReader<KeyValue> createRecordReader(DataFileMeta file)
                                          throws IOException

Specified by:

createRecordReader in interface FileReaderFactory<KeyValue>

Throws:

IOException

createRecordReader

public RecordReader<KeyValue> createRecordReader(long schemaId,
                                                 String fileName,
                                                 long fileSize,
                                                 int level)
                                          throws IOException

Throws:

IOException

builder

public static KeyValueFileReaderFactory.Builder builder(FileIO fileIO,
                                                        SchemaManager schemaManager,
                                                        TableSchema schema,
                                                        RowType keyType,
                                                        RowType valueType,
                                                        FileFormatDiscover formatDiscover,
                                                        FileStorePathFactory pathFactory,
                                                        KeyValueFieldsExtractor extractor,
                                                        CoreOptions options)