org.apache.paimon.mergetree.compact

Class LookupChangelogMergeFunctionWrapper<T>

java.lang.Object

org.apache.paimon.mergetree.compact.LookupChangelogMergeFunctionWrapper<T>

All Implemented Interfaces:

MergeFunctionWrapper<ChangelogResult>

public class LookupChangelogMergeFunctionWrapper<T>
extends Object
implements MergeFunctionWrapper<ChangelogResult>

Wrapper for MergeFunctions to produce changelog by lookup during the compaction involving level 0 files.

Changelog records are generated in the process of the level-0 file participating in the compaction, if during the compaction processing:

• Without level-0 records, no changelog.
• With level-0 record, with level-x (x > 0) record, level-x record should be BEFORE, level-0 should be AFTER.
• With level-0 record, without level-x record, need to lookup the history value of the upper level as BEFORE.

Constructor Summary

Constructors

Constructor and Description
LookupChangelogMergeFunctionWrapper(MergeFunctionFactory<KeyValue> mergeFunctionFactory, java.util.function.Function<InternalRow,T> lookup, RecordEqualiser valueEqualiser, LookupStrategy lookupStrategy, DeletionVectorsMaintainer deletionVectorsMaintainer, UserDefinedSeqComparator userDefinedSeqComparator)

Method Summary

Modifier and Type	Method and Description
void	add(KeyValue kv)
ChangelogResult	getResult()
void	reset()

Methods inherited from class java.lang.Object

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

Constructor Detail

LookupChangelogMergeFunctionWrapper

public LookupChangelogMergeFunctionWrapper(MergeFunctionFactory<KeyValue> mergeFunctionFactory,
                                           java.util.function.Function<InternalRow,T> lookup,
                                           @Nullable
                                           RecordEqualiser valueEqualiser,
                                           LookupStrategy lookupStrategy,
                                           @Nullable
                                           DeletionVectorsMaintainer deletionVectorsMaintainer,
                                           @Nullable
                                           UserDefinedSeqComparator userDefinedSeqComparator)

Method Detail

reset

public void reset()

Specified by:

reset in interface MergeFunctionWrapper<ChangelogResult>

add

public void add(KeyValue kv)

Specified by:

add in interface MergeFunctionWrapper<ChangelogResult>

getResult

public ChangelogResult getResult()

Specified by:

getResult in interface MergeFunctionWrapper<ChangelogResult>