Package org.apache.flink.streaming.api.runners.python.beam

Class Summary

Class	Description
BeamDataStreamPythonFunctionRunner	BeamDataStreamPythonFunctionRunner is responsible for starting a beam python harness to execute user defined python function.
BeamPythonFunctionRunner	A BeamPythonFunctionRunner used to execute Python functions.
PythonSharedResources	The set of resources that can be shared by all the Python operators in a slot.