Package | Description |
---|---|
org.apache.flink.python.env | |
org.apache.flink.python.env.beam |
Modifier and Type | Class and Description |
---|---|
class |
ProcessPythonEnvironment
A
PythonEnvironment for executing UDFs in Process. |
Modifier and Type | Method and Description |
---|---|
PythonEnvironment |
PythonEnvironmentManager.createEnvironment()
Creates the PythonEnvironment object used in
PythonFunctionRunner . |
Modifier and Type | Method and Description |
---|---|
PythonEnvironment |
ProcessPythonEnvironmentManager.createEnvironment() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.