Uses of Interface
org.apache.flink.table.functions.python.PythonFunction

Packages that use PythonFunction

Package	Description
org.apache.flink.client.python
org.apache.flink.streaming.api.functions.python
org.apache.flink.table.functions.python
org.apache.flink.table.functions.python.utils

Uses of PythonFunction in org.apache.flink.client.python

Methods in org.apache.flink.client.python that return PythonFunction

Modifier and Type	Method and Description
static PythonFunction	PythonFunctionFactory.getPythonFunction(String fullyQualifiedName, ReadableConfig config, ClassLoader classLoader) Returns PythonFunction according to the fully qualified name of the Python UDF i.e ${moduleName}.
PythonFunction	PythonFunctionFactoryImpl.getPythonFunction(String moduleName, String objectName)
PythonFunction	PythonFunctionFactory.getPythonFunction(String moduleName, String objectName) Returns PythonFunction according to moduleName and objectName.

Uses of PythonFunction in org.apache.flink.streaming.api.functions.python

Classes in org.apache.flink.streaming.api.functions.python that implement PythonFunction

Modifier and Type	Class and Description
class	DataStreamPythonFunction DataStreamPythonFunction maintains the serialized python function which will be used in BeamDataStreamPythonFunctionRunner.

Constructors in org.apache.flink.streaming.api.functions.python with parameters of type PythonFunction

Constructor and Description
DataStreamPythonFunctionInfo(PythonFunction pythonFunction, DataStreamPythonFunctionInfo input, int functionType)
DataStreamPythonFunctionInfo(PythonFunction pythonFunction, int functionType)

Uses of PythonFunction in org.apache.flink.table.functions.python

Classes in org.apache.flink.table.functions.python that implement PythonFunction

Modifier and Type	Class and Description
class	BuiltInPythonAggregateFunction The list of the built-in aggregate functions which can be mixed with the Python UDAF.
class	PythonAggregateFunction The wrapper of user defined python aggregate function.
class	PythonScalarFunction The wrapper of user defined python scalar function.
class	PythonTableAggregateFunction The wrapper of user defined python table aggregate function.
class	PythonTableFunction The wrapper of user defined python table function.

Methods in org.apache.flink.table.functions.python that return PythonFunction

Modifier and Type	Method and Description
PythonFunction	PythonFunctionInfo.getPythonFunction()

Constructors in org.apache.flink.table.functions.python with parameters of type PythonFunction

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

Uses of PythonFunction in org.apache.flink.table.functions.python.utils

Methods in org.apache.flink.table.functions.python.utils that return PythonFunction

Modifier and Type	Method and Description
static PythonFunction	PythonFunctionUtils.getPythonFunction(String fullyQualifiedName, ReadableConfig config, ClassLoader classLoader)