Uses of Class
org.apache.flink.table.functions.python.PythonAggregateFunctionInfo

Packages that use PythonAggregateFunctionInfo

Package	Description
org.apache.flink.streaming.api.utils
org.apache.flink.table.runtime.operators.python.aggregate

Uses of PythonAggregateFunctionInfo in org.apache.flink.streaming.api.utils

Methods in org.apache.flink.streaming.api.utils with parameters of type PythonAggregateFunctionInfo

Modifier and Type	Method and Description
static FlinkFnApi.UserDefinedAggregateFunction	PythonOperatorUtils.getUserDefinedAggregateFunctionProto(PythonAggregateFunctionInfo pythonFunctionInfo, DataViewUtils.DataViewSpec[] dataViewSpecs)

Uses of PythonAggregateFunctionInfo in org.apache.flink.table.runtime.operators.python.aggregate

Constructors in org.apache.flink.table.runtime.operators.python.aggregate with parameters of type PythonAggregateFunctionInfo

Constructor and Description
PythonStreamGroupAggregateOperator(Configuration config, RowType inputType, RowType outputType, PythonAggregateFunctionInfo[] aggregateFunctions, DataViewUtils.DataViewSpec[][] dataViewSpecs, int[] grouping, int indexOfCountStar, boolean countStarInserted, boolean generateUpdateBefore, long minRetentionTime, long maxRetentionTime)