org.apache.paimon.mergetree

Class MergeTreeReaders

java.lang.Object

org.apache.paimon.mergetree.MergeTreeReaders

public class MergeTreeReaders
extends Object

Utility class to create commonly used RecordReaders for merge trees.

Method Summary

Modifier and Type	Method and Description
static <T> RecordReader<T>	readerForMergeTree(List<List<SortedRun>> sections, FileReaderFactory<KeyValue> readerFactory, Comparator<InternalRow> userKeyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper, MergeSorter mergeSorter)
static <T> RecordReader<T>	readerForSection(List<SortedRun> section, FileReaderFactory<KeyValue> readerFactory, Comparator<InternalRow> userKeyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper, MergeSorter mergeSorter)

Methods inherited from class java.lang.Object

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

Method Detail

readerForMergeTree

public static <T> RecordReader<T> readerForMergeTree(List<List<SortedRun>> sections,
                                                     FileReaderFactory<KeyValue> readerFactory,
                                                     Comparator<InternalRow> userKeyComparator,
                                                     @Nullable
                                                     FieldsComparator userDefinedSeqComparator,
                                                     MergeFunctionWrapper<T> mergeFunctionWrapper,
                                                     MergeSorter mergeSorter)
                                              throws IOException

Throws:

IOException

readerForSection

public static <T> RecordReader<T> readerForSection(List<SortedRun> section,
                                                   FileReaderFactory<KeyValue> readerFactory,
                                                   Comparator<InternalRow> userKeyComparator,
                                                   @Nullable
                                                   FieldsComparator userDefinedSeqComparator,
                                                   MergeFunctionWrapper<T> mergeFunctionWrapper,
                                                   MergeSorter mergeSorter)
                                            throws IOException

Throws:

IOException