Package org.apache.flink.table.functions.python

Class PythonAggregateFunctionInfo

java.lang.Object

org.apache.flink.table.functions.python.PythonFunctionInfo

org.apache.flink.table.functions.python.PythonAggregateFunctionInfo

All Implemented Interfaces:

Serializable

@Internal
public class PythonAggregateFunctionInfo
extends PythonFunctionInfo

PythonAggregateFunctionInfo contains the execution information of a Python aggregate function, such as: the actual Python aggregation function, the input arguments, the filter arg, the distinct flag, etc.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
PythonAggregateFunctionInfo(PythonFunction pythonFunction, Object[] inputs, int filterArg, boolean isDistinct)

Method Summary

Modifier and Type	Method	Description
int	getFilterArg()
boolean	isDistinct()

Methods inherited from class org.apache.flink.table.functions.python.PythonFunctionInfo

getInputs, getPythonFunction, setInputs

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PythonAggregateFunctionInfo

public PythonAggregateFunctionInfo(PythonFunction pythonFunction,
                                   Object[] inputs,
                                   int filterArg,
                                   boolean isDistinct)

Method Detail

isDistinct

public boolean isDistinct()

getFilterArg

public int getFilterArg()