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.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.