Package | Description |
---|---|
org.apache.flink.streaming.api.operators.python | |
org.apache.flink.table.functions.python | |
org.apache.flink.table.runtime.operators.python |
Modifier and Type | Method and Description |
---|---|
abstract PythonEnv |
AbstractPythonFunctionOperator.getPythonEnv()
Returns the
PythonEnv used to create PythonEnvironmentManager.. |
Modifier and Type | Method and Description |
---|---|
PythonEnv |
PythonFunction.getPythonEnv()
Returns the Python execution environment.
|
PythonEnv |
SimplePythonFunction.getPythonEnv() |
Constructor and Description |
---|
SimplePythonFunction(byte[] serializedPythonFunction,
PythonEnv pythonEnv) |
Modifier and Type | Method and Description |
---|---|
PythonEnv |
AbstractPythonScalarFunctionOperator.getPythonEnv() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.