Package org.apache.flink.table.runtime.operators.aggregate

Class Summary

Class	Description
BytesHashMapSpillMemorySegmentPool	MemorySegmentPool for BytesHashMap to fall back to sort agg.
GroupAggFunction	Aggregate Function used for the groupby (without window) aggregate.
GroupAggFunctionBase	Base class for GroupAggFunction and AsyncStateGroupAggFunction.
GroupTableAggFunction	Aggregate Function used for the groupby (without window) table aggregate.
MiniBatchGlobalGroupAggFunction	Aggregate Function used for the global groupby (without window) aggregate in miniBatch mode.
MiniBatchGroupAggFunction	Aggregate Function used for the groupby (without window) aggregate in miniBatch mode.
MiniBatchIncrementalGroupAggFunction	Aggregate Function used for the incremental groupby (without window) aggregate in miniBatch mode.
MiniBatchLocalGroupAggFunction	Aggregate Function used for the local groupby (without window) aggregate in miniBatch mode.
RecordCounter	The RecordCounter is used to count the number of input records under the current key.