org.apache.paimon.mergetree.compact

Class LookupMergeTreeCompactRewriter.LookupMergeFunctionWrapperFactory<T>

java.lang.Object

org.apache.paimon.mergetree.compact.LookupMergeTreeCompactRewriter.LookupMergeFunctionWrapperFactory<T>

All Implemented Interfaces:

LookupMergeTreeCompactRewriter.MergeFunctionWrapperFactory<T>

Enclosing class:

LookupMergeTreeCompactRewriter<T>

public static class LookupMergeTreeCompactRewriter.LookupMergeFunctionWrapperFactory<T>
extends Object
implements LookupMergeTreeCompactRewriter.MergeFunctionWrapperFactory<T>

A normal LookupMergeTreeCompactRewriter.MergeFunctionWrapperFactory to create lookup wrapper.

Constructor Summary

Constructors

Constructor and Description
LookupMergeFunctionWrapperFactory(RecordEqualiser valueEqualiser, LookupStrategy lookupStrategy, UserDefinedSeqComparator userDefinedSeqComparator)

Method Summary

Modifier and Type	Method and Description
MergeFunctionWrapper<ChangelogResult>	create(MergeFunctionFactory<KeyValue> mfFactory, int outputLevel, LookupLevels<T> lookupLevels, DeletionVectorsMaintainer deletionVectorsMaintainer)

Methods inherited from class java.lang.Object

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

Constructor Detail

LookupMergeFunctionWrapperFactory

public LookupMergeFunctionWrapperFactory(@Nullable
                                         RecordEqualiser valueEqualiser,
                                         LookupStrategy lookupStrategy,
                                         @Nullable
                                         UserDefinedSeqComparator userDefinedSeqComparator)

Method Detail

create

public MergeFunctionWrapper<ChangelogResult> create(MergeFunctionFactory<KeyValue> mfFactory,
                                                    int outputLevel,
                                                    LookupLevels<T> lookupLevels,
                                                    @Nullable
                                                    DeletionVectorsMaintainer deletionVectorsMaintainer)

Specified by:

create in interface LookupMergeTreeCompactRewriter.MergeFunctionWrapperFactory<T>