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

Constructor Summary

Constructors

Constructor and Description
FieldAggregator(DataType dataType)

Method Summary

Modifier and Type	Method and Description
abstract Object	agg(Object accumulator, Object inputField)
Object	aggReversed(Object accumulator, Object inputField)
static FieldAggregator	createFieldAggregator(DataType fieldType, String strAgg, boolean ignoreRetract, boolean isPrimaryKey, CoreOptions options, String field)
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 DataType fieldType

Constructor Detail

FieldAggregator

public FieldAggregator(DataType dataType)

Method Detail

createFieldAggregator

public static FieldAggregator createFieldAggregator(DataType fieldType,
                                                    @Nullable
                                                    String strAgg,
                                                    boolean ignoreRetract,
                                                    boolean isPrimaryKey,
                                                    CoreOptions options,
                                                    String field)

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)