org.apache.paimon.mergetree.compact

Class FullChangelogMergeFunctionWrapper

java.lang.Object

org.apache.paimon.mergetree.compact.FullChangelogMergeFunctionWrapper

All Implemented Interfaces:

MergeFunctionWrapper<ChangelogResult>

public class FullChangelogMergeFunctionWrapper
extends Object
implements MergeFunctionWrapper<ChangelogResult>

Wrapper for MergeFunctions to produce changelog during a full compaction.

This wrapper can only be used in SortMergeReader because

• This wrapper does not copy KeyValues. As KeyValues are reused by readers this may cause issues in other readers.
• KeyValues with the same key come from different inner readers in SortMergeReader, so there is no issue related to object reuse.

Constructor Summary

Constructors

Constructor and Description
FullChangelogMergeFunctionWrapper(MergeFunction<KeyValue> mergeFunction, int maxLevel, RecordEqualiser valueEqualiser)

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

FullChangelogMergeFunctionWrapper

public FullChangelogMergeFunctionWrapper(MergeFunction<KeyValue> mergeFunction,
                                         int maxLevel,
                                         @Nullable
                                         RecordEqualiser valueEqualiser)

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>