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

Packages that use PythonEnv

Package	Description
org.apache.flink.streaming.api.functions.python
org.apache.flink.streaming.api.operators.python.process
org.apache.flink.table.functions.python
org.apache.flink.table.runtime.operators.python.aggregate
org.apache.flink.table.runtime.operators.python.aggregate.arrow
org.apache.flink.table.runtime.operators.python.scalar
org.apache.flink.table.runtime.operators.python.table

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

Methods in org.apache.flink.streaming.api.functions.python that return PythonEnv

Modifier and Type	Method and Description
PythonEnv	DataStreamPythonFunction.getPythonEnv()

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

Constructor and Description
DataStreamPythonFunction(byte[] serializedPythonFunction, PythonEnv pythonEnv)

Uses of PythonEnv in org.apache.flink.streaming.api.operators.python.process

Methods in org.apache.flink.streaming.api.operators.python.process that return PythonEnv

Modifier and Type	Method and Description
PythonEnv	AbstractExternalDataStreamPythonFunctionOperator.getPythonEnv()
abstract PythonEnv	AbstractExternalPythonFunctionOperator.getPythonEnv() Returns the PythonEnv used to create PythonEnvironmentManager..

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

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

Modifier and Type	Method and Description
PythonEnv	PythonTableAggregateFunction.getPythonEnv()
PythonEnv	BuiltInPythonAggregateFunction.getPythonEnv()
PythonEnv	PythonTableFunction.getPythonEnv()
PythonEnv	PythonScalarFunction.getPythonEnv()
PythonEnv	PythonAggregateFunction.getPythonEnv()
PythonEnv	PythonFunction.getPythonEnv() Returns the Python execution environment.

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

Constructor and Description
PythonAggregateFunction(String name, byte[] serializedAggregateFunction, DataType[] inputTypes, DataType resultType, DataType accumulatorType, PythonFunctionKind pythonFunctionKind, boolean deterministic, boolean takesRowAsInput, PythonEnv pythonEnv)
PythonAggregateFunction(String name, byte[] serializedAggregateFunction, PythonFunctionKind pythonFunctionKind, boolean deterministic, boolean takesRowAsInput, PythonEnv pythonEnv)
PythonAggregateFunction(String name, byte[] serializedAggregateFunction, String[] inputTypesString, String resultTypeString, String accumulatorTypeString, PythonFunctionKind pythonFunctionKind, boolean deterministic, boolean takesRowAsInput, PythonEnv pythonEnv)
PythonScalarFunction(String name, byte[] serializedScalarFunction, DataType[] inputTypes, DataType resultType, PythonFunctionKind pythonFunctionKind, boolean deterministic, boolean takesRowAsInput, PythonEnv pythonEnv)
PythonScalarFunction(String name, byte[] serializedScalarFunction, PythonFunctionKind pythonFunctionKind, boolean deterministic, boolean takesRowAsInput, PythonEnv pythonEnv)
PythonScalarFunction(String name, byte[] serializedScalarFunction, String[] inputTypesString, String resultTypeString, PythonFunctionKind pythonFunctionKind, boolean deterministic, boolean takesRowAsInput, PythonEnv pythonEnv)
PythonTableAggregateFunction(String name, byte[] serializedTableAggregateFunction, DataType[] inputTypes, DataType resultType, DataType accumulatorType, PythonFunctionKind pythonFunctionKind, boolean deterministic, boolean takesRowAsInput, PythonEnv pythonEnv)
PythonTableAggregateFunction(String name, byte[] serializedTableAggregateFunction, PythonFunctionKind pythonFunctionKind, boolean deterministic, boolean takesRowAsInput, PythonEnv pythonEnv)
PythonTableAggregateFunction(String name, byte[] serializedTableAggregateFunction, String[] inputTypesString, String resultTypeString, String accumulatorTypeString, PythonFunctionKind pythonFunctionKind, boolean deterministic, boolean takesRowAsInput, PythonEnv pythonEnv)
PythonTableFunction(String name, byte[] serializedScalarFunction, DataType[] inputTypes, DataType resultType, PythonFunctionKind pythonFunctionKind, boolean deterministic, boolean takesRowAsInput, PythonEnv pythonEnv)
PythonTableFunction(String name, byte[] serializedScalarFunction, PythonFunctionKind pythonFunctionKind, boolean deterministic, boolean takesRowAsInput, PythonEnv pythonEnv)
PythonTableFunction(String name, byte[] serializedScalarFunction, String[] inputTypesString, String resultTypeString, PythonFunctionKind pythonFunctionKind, boolean deterministic, boolean takesRowAsInput, PythonEnv pythonEnv)

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

Methods in org.apache.flink.table.runtime.operators.python.aggregate that return PythonEnv

Modifier and Type	Method and Description
PythonEnv	AbstractPythonStreamAggregateOperator.getPythonEnv()

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

Methods in org.apache.flink.table.runtime.operators.python.aggregate.arrow that return PythonEnv

Modifier and Type	Method and Description
PythonEnv	AbstractArrowPythonAggregateFunctionOperator.getPythonEnv()

Uses of PythonEnv in org.apache.flink.table.runtime.operators.python.scalar

Methods in org.apache.flink.table.runtime.operators.python.scalar that return PythonEnv

Modifier and Type	Method and Description
PythonEnv	AbstractPythonScalarFunctionOperator.getPythonEnv()

Uses of PythonEnv in org.apache.flink.table.runtime.operators.python.table

Methods in org.apache.flink.table.runtime.operators.python.table that return PythonEnv

Modifier and Type	Method and Description
PythonEnv	PythonTableFunctionOperator.getPythonEnv()