org.apache.flink.table.functions.python

Interface PythonFunction

All Superinterfaces:

Serializable

All Known Implementing Classes:

BuiltInPythonAggregateFunction, DataStreamPythonFunction, PythonAggregateFunction, PythonScalarFunction, PythonTableAggregateFunction, PythonTableFunction

@Internal
public interface PythonFunction
extends Serializable

The base interface of a wrapper of a Python function. It wraps the serialized Python function and the execution environment.

Method Summary

Modifier and Type	Method and Description
PythonEnv	getPythonEnv() Returns the Python execution environment.
default PythonFunctionKind	getPythonFunctionKind() Returns the kind of the user-defined python function.
byte[]	getSerializedPythonFunction() Returns the serialized representation of the user-defined python function.
default boolean	takesRowAsInput() Returns Whether the Python function takes row as input instead of each columns of a row.

Method Detail

getSerializedPythonFunction

byte[] getSerializedPythonFunction()

Returns the serialized representation of the user-defined python function.

getPythonEnv

PythonEnv getPythonEnv()

Returns the Python execution environment.

getPythonFunctionKind

default PythonFunctionKind getPythonFunctionKind()

Returns the kind of the user-defined python function.

takesRowAsInput

default boolean takesRowAsInput()

Returns Whether the Python function takes row as input instead of each columns of a row.