org.apache.paimon.mergetree.compact

Class DeduplicateMergeFunction

java.lang.Object

org.apache.paimon.mergetree.compact.DeduplicateMergeFunction

All Implemented Interfaces:

MergeFunction<KeyValue>

public class DeduplicateMergeFunction
extends Object
implements MergeFunction<KeyValue>

A MergeFunction where key is primary key (unique) and value is the full record, only keep the latest one.

Method Summary

Modifier and Type	Method and Description
void	add(KeyValue kv) Add the given KeyValue to the merge function.
static MergeFunctionFactory<KeyValue>	factory()
static MergeFunctionFactory<KeyValue>	factory(Options options)
KeyValue	getResult() Get current merged value.
boolean	requireCopy()
void	reset() Reset the merge function to its default state, call this before calling MergeFunction.add(KeyValue) for the first time or after MergeFunction.getResult().

Methods inherited from class java.lang.Object

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

Method Detail

reset

public void reset()

Description copied from interface: MergeFunction

Reset the merge function to its default state, call this before calling MergeFunction.add(KeyValue) for the first time or after MergeFunction.getResult().

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>

requireCopy

public boolean requireCopy()

Specified by:

requireCopy in interface MergeFunction<KeyValue>

factory

public static MergeFunctionFactory<KeyValue> factory()

factory

public static MergeFunctionFactory<KeyValue> factory(Options options)