Modifier and Type | Method and Description |
---|---|
PythonEnv |
DataStreamPythonFunction.getPythonEnv() |
Constructor and Description |
---|
DataStreamPythonFunction(byte[] serializedPythonFunction,
PythonEnv pythonEnv) |
Modifier and Type | Method and Description |
---|---|
PythonEnv |
TwoInputPythonFunctionOperator.getPythonEnv() |
PythonEnv |
PythonKeyedProcessOperator.getPythonEnv() |
abstract PythonEnv |
AbstractPythonFunctionOperator.getPythonEnv()
Returns the
PythonEnv used to create PythonEnvironmentManager.. |
PythonEnv |
OneInputPythonFunctionOperator.getPythonEnv() |
Modifier and Type | Method and Description |
---|---|
PythonEnv |
PythonTableFunction.getPythonEnv() |
PythonEnv |
PythonScalarFunction.getPythonEnv() |
PythonEnv |
PythonFunction.getPythonEnv()
Returns the Python execution environment.
|
PythonEnv |
BuiltInPythonAggregateFunction.getPythonEnv() |
PythonEnv |
PythonAggregateFunction.getPythonEnv() |
PythonEnv |
PythonTableAggregateFunction.getPythonEnv() |
Constructor and Description |
---|
PythonAggregateFunction(String name,
byte[] serializedAggregateFunction,
DataType[] inputTypes,
DataType resultType,
DataType accumulatorType,
PythonFunctionKind pythonFunctionKind,
boolean deterministic,
boolean takesRowAsInput,
PythonEnv pythonEnv) |
PythonScalarFunction(String name,
byte[] serializedScalarFunction,
TypeInformation[] inputTypes,
TypeInformation resultType,
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) |
PythonTableFunction(String name,
byte[] serializedScalarFunction,
TypeInformation[] inputTypes,
RowTypeInfo resultType,
PythonFunctionKind pythonFunctionKind,
boolean deterministic,
boolean takesRowAsInput,
PythonEnv pythonEnv) |
Modifier and Type | Method and Description |
---|---|
PythonEnv |
PythonTableFunctionFlatMap.getPythonEnv() |
PythonEnv |
AbstractPythonScalarFunctionFlatMap.getPythonEnv() |
abstract PythonEnv |
AbstractPythonStatelessFunctionFlatMap.getPythonEnv()
Returns the
PythonEnv used to create PythonEnvironmentManager.. |
Modifier and Type | Method and Description |
---|---|
PythonEnv |
AbstractPythonStreamAggregateOperator.getPythonEnv() |
Modifier and Type | Method and Description |
---|---|
PythonEnv |
AbstractArrowPythonAggregateFunctionOperator.getPythonEnv() |
Modifier and Type | Method and Description |
---|---|
PythonEnv |
AbstractPythonScalarFunctionOperator.getPythonEnv() |
Modifier and Type | Method and Description |
---|---|
PythonEnv |
AbstractPythonTableFunctionOperator.getPythonEnv() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.