public interface TableAggsHandleFunction extends AggsHandleFunctionBase
It is code generated to handle all
TableAggregateFunctions together in an aggregation.
It is the entry point for aggregate operators to operate all
|Modifier and Type||Method and Description|
Emit the result of the table aggregation through the collector.
accumulate, cleanup, close, createAccumulators, getAccumulators, merge, open, resetAccumulators, retract, setAccumulators
void emitValue(Collector<RowData> out, RowData currentKey, boolean isRetract) throws Exception
out- the collector used to emit records.
currentKey- the current group key.
isRetract- the retraction flag which indicates whether emit retract values.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.