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

Class Summary

Class	Description
AbstractPythonStreamAggregateOperator	Base class for AbstractPythonStreamGroupAggregateOperator and PythonStreamGroupWindowAggregateOperator.
AbstractPythonStreamGroupAggregateOperator	Base class for PythonStreamGroupAggregateOperator and PythonStreamGroupTableAggregateOperator.
PythonStreamGroupAggregateOperator	The Python AggregateFunction operator.
PythonStreamGroupTableAggregateOperator	The Python TableAggregateFunction operator.
PythonStreamGroupWindowAggregateOperator<K,W extends org.apache.flink.table.runtime.operators.window.Window>	The Python Group Window AggregateFunction operator.