org.apache.paimon.mergetree.compact

Class LookupMergeFunction

java.lang.Object

org.apache.paimon.mergetree.compact.LookupMergeFunction

All Implemented Interfaces:

MergeFunction<KeyValue>

public class LookupMergeFunction
extends Object
implements MergeFunction<KeyValue>

A MergeFunction for lookup, this wrapper only considers the latest high level record, because each merge will query the old merged record, so the latest high level record should be the final merged value.

Constructor Summary

Constructors

Constructor and Description
LookupMergeFunction(MergeFunction<KeyValue> mergeFunction, RowType keyType, RowType valueType)

Method Summary

Modifier and Type	Method and Description
void	add(KeyValue kv) Add the given KeyValue to the merge function.
KeyValue	getResult() Get current merged value.
void	reset() Reset the merge function to its default state.
static MergeFunctionFactory<KeyValue>	wrap(MergeFunctionFactory<KeyValue> wrapped, RowType keyType, RowType valueType)

Methods inherited from class java.lang.Object

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

Constructor Detail

LookupMergeFunction

public LookupMergeFunction(MergeFunction<KeyValue> mergeFunction,
                           RowType keyType,
                           RowType valueType)

Method Detail

reset

public void reset()

Description copied from interface: MergeFunction

Reset the merge function to its default state.

Specified by:

reset in interface MergeFunction<KeyValue>

add

public void add(KeyValue kv)

Description copied from interface: MergeFunction

Add the given KeyValue to the merge function.

Specified by:

add in interface MergeFunction<KeyValue>

getResult

public KeyValue getResult()

Description copied from interface: MergeFunction

Get current merged value.

Specified by:

getResult in interface MergeFunction<KeyValue>

wrap

public static MergeFunctionFactory<KeyValue> wrap(MergeFunctionFactory<KeyValue> wrapped,
                                                  RowType keyType,
                                                  RowType valueType)