org.apache.paimon.mergetree.compact

Class PartialUpdateMergeFunction

java.lang.Object

org.apache.paimon.mergetree.compact.PartialUpdateMergeFunction

All Implemented Interfaces:

MergeFunction<KeyValue>

public class PartialUpdateMergeFunction
extends Object
implements MergeFunction<KeyValue>

A MergeFunction where key is primary key (unique) and value is the partial record, update non-null fields on merge.

Field Summary

Fields

Modifier and Type	Field and Description
static String	SEQUENCE_GROUP

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PartialUpdateMergeFunction(InternalRow.FieldGetter[] getters, boolean ignoreDelete, Map<Integer,FieldsComparator> fieldSeqComparators, Map<Integer,FieldAggregator> fieldAggregators, boolean fieldSequenceEnabled, boolean removeRecordOnDelete, Set<Integer> sequenceGroupPartialDelete)

Method Summary

Modifier and Type	Method and Description
void	add(KeyValue kv) Add the given KeyValue to the merge function.
static MergeFunctionFactory<KeyValue>	factory(Options options, RowType rowType, List<String> primaryKeys)
KeyValue	getResult() Get current merged value.
void	reset() Reset the merge function to its default state.

Methods inherited from class java.lang.Object

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

Field Detail

SEQUENCE_GROUP

public static final String SEQUENCE_GROUP

See Also:

Constant Field Values

Constructor Detail

PartialUpdateMergeFunction

protected PartialUpdateMergeFunction(InternalRow.FieldGetter[] getters,
                                     boolean ignoreDelete,
                                     Map<Integer,FieldsComparator> fieldSeqComparators,
                                     Map<Integer,FieldAggregator> fieldAggregators,
                                     boolean fieldSequenceEnabled,
                                     boolean removeRecordOnDelete,
                                     Set<Integer> sequenceGroupPartialDelete)

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>

factory

public static MergeFunctionFactory<KeyValue> factory(Options options,
                                                     RowType rowType,
                                                     List<String> primaryKeys)