Modifier and Type | Field and Description |
---|---|
protected PythonFunctionRunner |
AbstractPythonFunctionOperator.pythonFunctionRunner
The
PythonFunctionRunner which is responsible for Python user-defined function
execution. |
Modifier and Type | Method and Description |
---|---|
PythonFunctionRunner |
TwoInputPythonFunctionOperator.createPythonFunctionRunner() |
PythonFunctionRunner |
PythonKeyedCoProcessOperator.createPythonFunctionRunner() |
PythonFunctionRunner |
PythonKeyedProcessOperator.createPythonFunctionRunner() |
abstract PythonFunctionRunner |
AbstractPythonFunctionOperator.createPythonFunctionRunner()
Creates the
PythonFunctionRunner which is responsible for Python user-defined
function execution. |
PythonFunctionRunner |
OneInputPythonFunctionOperator.createPythonFunctionRunner() |
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 | Field and Description |
---|---|
protected PythonFunctionRunner |
AbstractPythonStatelessFunctionFlatMap.pythonFunctionRunner
The
PythonFunctionRunner which is responsible for Python user-defined function
execution. |
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 |
BeamTableStatefulPythonFunctionRunner
A
BeamTableStatefulPythonFunctionRunner used to execute Python stateful functions. |
class |
BeamTableStatelessPythonFunctionRunner
A
BeamTableStatelessPythonFunctionRunner used to execute Python stateless functions. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.