Class | Description |
---|---|
AbstractExternalDataStreamPythonFunctionOperator<OUT> |
Base class for all Python DataStream operators executed in Python process.
|
AbstractExternalOneInputPythonFunctionOperator<IN,OUT> |
AbstractExternalOneInputPythonFunctionOperator is responsible for launching beam runner
which will start a python harness to execute user defined python function. |
AbstractExternalPythonFunctionOperator<OUT> |
Abstract class for all stream operators to execute Python functions in external environment.
|
AbstractExternalTwoInputPythonFunctionOperator<IN1,IN2,OUT> |
AbstractExternalTwoInputPythonFunctionOperator is responsible for launching beam runner
which will start a python harness to execute two-input user defined python function. |
ExternalPythonBatchCoBroadcastProcessOperator<IN1,IN2,OUT> |
The
ExternalPythonBatchCoBroadcastProcessOperator is responsible for executing the Python
CoBroadcastProcess Function under BATCH mode, ExternalPythonCoProcessOperator is used
under STREAMING mode. |
ExternalPythonBatchKeyedCoBroadcastProcessOperator<OUT> |
The
ExternalPythonBatchKeyedCoBroadcastProcessOperator is responsible for executing the
Python CoBroadcastProcess function under BATCH mode, ExternalPythonKeyedCoProcessOperator
is used under STREAMING mode. |
ExternalPythonCoProcessOperator<IN1,IN2,OUT> |
The
ExternalPythonCoProcessOperator is responsible for executing the Python CoProcess
Function. |
ExternalPythonKeyedCoProcessOperator<OUT> |
ExternalPythonKeyedCoProcessOperator is responsible for launching beam runner which will
start a python harness to execute user defined python CoProcess function. |
ExternalPythonKeyedProcessOperator<OUT> |
ExternalPythonKeyedProcessOperator is responsible for launching beam runner which will
start a python harness to execute user defined python function. |
ExternalPythonProcessOperator<IN,OUT> |
ExternalPythonProcessOperator 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.