Modifier and Type | Field and Description |
---|---|
protected PythonFunctionRunner |
AbstractExternalPythonFunctionOperator.pythonFunctionRunner
The
PythonFunctionRunner which is responsible for Python user-defined function
execution. |
Modifier and Type | Method and Description |
---|---|
PythonFunctionRunner |
ExternalPythonCoProcessOperator.createPythonFunctionRunner() |
PythonFunctionRunner |
ExternalPythonProcessOperator.createPythonFunctionRunner() |
PythonFunctionRunner |
ExternalPythonKeyedProcessOperator.createPythonFunctionRunner() |
PythonFunctionRunner |
ExternalPythonKeyedCoProcessOperator.createPythonFunctionRunner() |
abstract PythonFunctionRunner |
AbstractExternalPythonFunctionOperator.createPythonFunctionRunner()
Creates the
PythonFunctionRunner which is responsible for Python user-defined
function execution. |
Modifier and Type | Class and Description |
---|---|
class |
BeamDataStreamPythonFunctionRunner
BeamDataStreamPythonFunctionRunner is responsible for starting a beam python harness to
execute user defined python function. |
class |
BeamPythonFunctionRunner
A
BeamPythonFunctionRunner used to execute Python functions. |
Modifier and Type | Method and Description |
---|---|
PythonFunctionRunner |
AbstractStatelessFunctionOperator.createPythonFunctionRunner() |
Modifier and Type | Method and Description |
---|---|
PythonFunctionRunner |
AbstractPythonStreamAggregateOperator.createPythonFunctionRunner() |
Modifier and Type | Class and Description |
---|---|
class |
BeamTablePythonFunctionRunner
A
BeamTablePythonFunctionRunner used to execute Python functions in Table API. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.