Package org.apache.flink.python.env.process
-
Class Summary Class Description ProcessPythonEnvironment APythonEnvironment
for executing UDFs in Process.ProcessPythonEnvironmentManager The ProcessPythonEnvironmentManager is used to prepare the working dir of python UDF worker and create ProcessPythonEnvironment object of Beam Fn API.