public class MergeTreeReaders extends Object
RecordReader
s for merge trees.Modifier and Type | Method and Description |
---|---|
static RecordReader<KeyValue> |
readerForMergeTree(List<List<SortedRun>> sections,
boolean dropDelete,
KeyValueFileReaderFactory readerFactory,
Comparator<org.apache.flink.table.data.RowData> userKeyComparator,
MergeFunction<KeyValue> mergeFunction) |
static RecordReader<KeyValue> |
readerForRun(SortedRun run,
KeyValueFileReaderFactory readerFactory) |
static RecordReader<KeyValue> |
readerForSection(List<SortedRun> section,
KeyValueFileReaderFactory readerFactory,
Comparator<org.apache.flink.table.data.RowData> userKeyComparator,
MergeFunctionWrapper<KeyValue> mergeFunctionWrapper) |
public static RecordReader<KeyValue> readerForMergeTree(List<List<SortedRun>> sections, boolean dropDelete, KeyValueFileReaderFactory readerFactory, Comparator<org.apache.flink.table.data.RowData> userKeyComparator, MergeFunction<KeyValue> mergeFunction) throws IOException
IOException
public static RecordReader<KeyValue> readerForSection(List<SortedRun> section, KeyValueFileReaderFactory readerFactory, Comparator<org.apache.flink.table.data.RowData> userKeyComparator, MergeFunctionWrapper<KeyValue> mergeFunctionWrapper) throws IOException
IOException
public static RecordReader<KeyValue> readerForRun(SortedRun run, KeyValueFileReaderFactory readerFactory) throws IOException
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.