org.apache.paimon.mergetree.compact.aggregate

Class FieldAggregator

java.lang.Object

org.apache.paimon.mergetree.compact.aggregate.FieldAggregator

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

FieldBoolAndAgg, FieldBoolOrAgg, FieldCollectAgg, FieldFirstNonNullValueAgg, FieldFirstValueAgg, FieldHllSketchAgg, FieldIgnoreRetractAgg, FieldLastNonNullValueAgg, FieldLastValueAgg, FieldListaggAgg, FieldMaxAgg, FieldMergeMapAgg, FieldMinAgg, FieldNestedUpdateAgg, FieldPrimaryKeyAgg, FieldProductAgg, FieldRoaringBitmap32Agg, FieldRoaringBitmap64Agg, FieldSumAgg, FieldThetaSketchAgg

public abstract class FieldAggregator
extends Object
implements Serializable

abstract class of aggregating a field of a row.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected DataType	fieldType
protected String	name

Constructor Summary

Constructors

Constructor and Description
FieldAggregator(String name, DataType dataType)

Method Summary

Modifier and Type	Method and Description
abstract Object	agg(Object accumulator, Object inputField)
Object	aggReversed(Object accumulator, Object inputField)
void	reset() reset the aggregator to a clean start state.
Object	retract(Object accumulator, Object retractField)

Methods inherited from class java.lang.Object

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

Field Detail

fieldType

protected final DataType fieldType

name

protected final String name

Constructor Detail

FieldAggregator

public FieldAggregator(String name,
                       DataType dataType)

Method Detail

agg

public abstract Object agg(Object accumulator,
                           Object inputField)

aggReversed

public Object aggReversed(Object accumulator,
                          Object inputField)

reset

public void reset()

reset the aggregator to a clean start state.

retract

public Object retract(Object accumulator,
                      Object retractField)