Interface TableAggsHandleFunction
-
- All Superinterfaces:
AggsHandleFunctionBase
,Function
,Serializable
public interface TableAggsHandleFunction extends AggsHandleFunctionBase
The base class for handling table aggregate functions.It is code generated to handle all
TableAggregateFunction
s together in an aggregation.It is the entry point for aggregate operators to operate all
TableAggregateFunction
s.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
emitValue(Collector<RowData> out, RowData currentKey, boolean isRetract)
Emit the result of the table aggregation through the collector.-
Methods inherited from interface org.apache.flink.table.runtime.generated.AggsHandleFunctionBase
accumulate, cleanup, close, createAccumulators, getAccumulators, merge, open, resetAccumulators, retract, setAccumulators
-
-
-
-
Method Detail
-
emitValue
void emitValue(Collector<RowData> out, RowData currentKey, boolean isRetract) throws Exception
Emit the result of the table aggregation through the collector.- Parameters:
out
- the collector used to emit records.currentKey
- the current group key.isRetract
- the retraction flag which indicates whether emit retract values.- Throws:
Exception
-
-