org.apache.paimon.mergetree.compact

Class FirstRowMergeFunctionWrapper

java.lang.Object

org.apache.paimon.mergetree.compact.FirstRowMergeFunctionWrapper

All Implemented Interfaces:

MergeFunctionWrapper<ChangelogResult>

public class FirstRowMergeFunctionWrapper
extends Object
implements MergeFunctionWrapper<ChangelogResult>

Wrapper for MergeFunctions to produce changelog by lookup for first row.

Constructor Summary

Constructors

Constructor and Description
FirstRowMergeFunctionWrapper(MergeFunctionFactory<KeyValue> mergeFunctionFactory, Filter<InternalRow> contains)

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

FirstRowMergeFunctionWrapper

public FirstRowMergeFunctionWrapper(MergeFunctionFactory<KeyValue> mergeFunctionFactory,
                                    Filter<InternalRow> contains)

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>