Uses of Interface
org.apache.paimon.mergetree.compact.MergeFunctionWrapper

Packages that use MergeFunctionWrapper

Package	Description
org.apache.paimon.mergetree
org.apache.paimon.mergetree.compact

Uses of MergeFunctionWrapper in org.apache.paimon.mergetree

Methods in org.apache.paimon.mergetree with parameters of type MergeFunctionWrapper

Modifier and Type	Method and Description
<T> RecordReader<T>	MergeSorter.mergeSort(List<SizedReaderSupplier<KeyValue>> lazyReaders, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunction)
<T> RecordReader<T>	MergeSorter.mergeSortNoSpill(List<? extends ReaderSupplier<KeyValue>> lazyReaders, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunction)
static <T> RecordReader<T>	MergeTreeReaders.readerForMergeTree(List<List<SortedRun>> sections, FileReaderFactory<KeyValue> readerFactory, Comparator<InternalRow> userKeyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper, MergeSorter mergeSorter)
static <T> RecordReader<T>	MergeTreeReaders.readerForSection(List<SortedRun> section, FileReaderFactory<KeyValue> readerFactory, Comparator<InternalRow> userKeyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper, MergeSorter mergeSorter)

Uses of MergeFunctionWrapper in org.apache.paimon.mergetree.compact

Classes in org.apache.paimon.mergetree.compact that implement MergeFunctionWrapper

Modifier and Type	Class and Description
class	FirstRowMergeFunctionWrapper Wrapper for MergeFunctions to produce changelog by lookup for first row.
class	FullChangelogMergeFunctionWrapper Wrapper for MergeFunctions to produce changelog during a full compaction.
class	LookupChangelogMergeFunctionWrapper<T> Wrapper for MergeFunctions to produce changelog by lookup during the compaction involving level 0 files.
class	ReducerMergeFunctionWrapper Wrapper for MergeFunctions which works like a reducer.

Methods in org.apache.paimon.mergetree.compact that return MergeFunctionWrapper

Modifier and Type	Method and Description
MergeFunctionWrapper<ChangelogResult>	LookupMergeTreeCompactRewriter.FirstRowMergeFunctionWrapperFactory.create(MergeFunctionFactory<KeyValue> mfFactory, int outputLevel, LookupLevels<Boolean> lookupLevels, DeletionVectorsMaintainer deletionVectorsMaintainer)
MergeFunctionWrapper<ChangelogResult>	LookupMergeTreeCompactRewriter.MergeFunctionWrapperFactory.create(MergeFunctionFactory<KeyValue> mfFactory, int outputLevel, LookupLevels<T> lookupLevels, DeletionVectorsMaintainer deletionVectorsMaintainer)
MergeFunctionWrapper<ChangelogResult>	LookupMergeTreeCompactRewriter.LookupMergeFunctionWrapperFactory.create(MergeFunctionFactory<KeyValue> mfFactory, int outputLevel, LookupLevels<T> lookupLevels, DeletionVectorsMaintainer deletionVectorsMaintainer)
protected MergeFunctionWrapper<ChangelogResult>	LookupMergeTreeCompactRewriter.createMergeWrapper(int outputLevel)
protected abstract MergeFunctionWrapper<ChangelogResult>	ChangelogMergeTreeRewriter.createMergeWrapper(int outputLevel)
protected MergeFunctionWrapper<ChangelogResult>	FullChangelogMergeTreeCompactRewriter.createMergeWrapper(int outputLevel)

Methods in org.apache.paimon.mergetree.compact with parameters of type MergeFunctionWrapper

Modifier and Type	Method and Description
static <T> SortMergeReader<T>	SortMergeReader.createSortMergeReader(List<RecordReader<KeyValue>> readers, Comparator<InternalRow> userKeyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper, CoreOptions.SortEngine sortEngine)
protected <T> RecordReader<T>	MergeTreeCompactRewriter.readerForMergeTree(List<List<SortedRun>> sections, MergeFunctionWrapper<T> mergeFunctionWrapper)

Constructors in org.apache.paimon.mergetree.compact with parameters of type MergeFunctionWrapper

Constructor and Description
SortMergeReaderWithLoserTree(List<RecordReader<KeyValue>> readers, Comparator<InternalRow> userKeyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper)
SortMergeReaderWithMinHeap(List<RecordReader<KeyValue>> readers, Comparator<InternalRow> userKeyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper)