Class | Description |
---|---|
AbstractDataStreamPythonFunctionOperator<OUT> |
Base class for all Python DataStream operators.
|
AbstractOneInputPythonFunctionOperator<IN,OUT> |
AbstractOneInputPythonFunctionOperator is responsible for launching beam runner which
will start a python harness to execute user defined python function. |
AbstractPythonFunctionOperator<OUT> |
Base class for all stream operators to execute Python functions.
|
AbstractTwoInputPythonFunctionOperator<IN1,IN2,OUT> |
AbstractTwoInputPythonFunctionOperator is responsible for launching beam runner which
will start a python harness to execute two-input user defined python function. |
PythonCoProcessOperator<IN1,IN2,OUT> |
The
PythonCoProcessOperator is responsible for executing the Python CoProcess Function. |
PythonKeyedCoProcessOperator<OUT> |
KeyedCoProcessOperator.
|
PythonKeyedProcessOperator<OUT> |
PythonKeyedProcessOperator is responsible for launching beam runner which will start a
python harness to execute user defined python function. |
PythonProcessOperator<IN,OUT> |
PythonProcessOperator is responsible for launching beam runner which will start a python
harness to execute user defined python ProcessFunction. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.