Class | Description |
---|---|
AbstractEmbeddedDataStreamPythonFunctionOperator<OUT> |
Base class for all Python DataStream operators executed in embedded Python environment.
|
AbstractEmbeddedPythonFunctionOperator<OUT> |
Abstract class for all stream operators to execute Python functions in embedded Python
environment.
|
AbstractOneInputEmbeddedPythonFunctionOperator<IN,OUT> |
AbstractOneInputEmbeddedPythonFunctionOperator is responsible for run Python DataStream
operators with one input in Embedded Python environment. |
AbstractTwoInputEmbeddedPythonFunctionOperator<IN1,IN2,OUT> |
AbstractTwoInputEmbeddedPythonFunctionOperator is responsible for run Python DataStream
operators with two input user defined python function in Embedded Python environment. |
EmbeddedPythonBatchCoBroadcastProcessOperator<IN1,IN2,OUT> |
The
EmbeddedPythonBatchCoBroadcastProcessOperator is responsible for executing the Python
CoBroadcastProcess Function under BATCH mode, EmbeddedPythonCoProcessOperator is used
under STREAMING mode. |
EmbeddedPythonBatchKeyedCoBroadcastProcessOperator<K,IN1,IN2,OUT> |
The
EmbeddedPythonBatchKeyedCoBroadcastProcessOperator is responsible for executing the
Python CoBroadcastProcess function under BATCH mode, EmbeddedPythonKeyedCoProcessOperator
is used under STREAMING mode. |
EmbeddedPythonCoProcessOperator<IN1,IN2,OUT> |
EmbeddedPythonCoProcessOperator is responsible for executing Python CoProcessFunction in
embedded Python environment. |
EmbeddedPythonKeyedCoProcessOperator<K,IN1,IN2,OUT> |
EmbeddedPythonKeyedCoProcessOperator is responsible for executing user defined python
KeyedCoProcessFunction in embedded Python environment. |
EmbeddedPythonKeyedProcessOperator<K,IN,OUT> |
EmbeddedPythonKeyedProcessOperator is responsible for executing user defined python
KeyedProcessFunction in embedded Python environment. |
EmbeddedPythonProcessOperator<IN,OUT> |
EmbeddedPythonProcessOperator is responsible for executing Python ProcessFunction in
embedded Python environment. |
EmbeddedPythonWindowOperator<K,IN,OUT,W extends Window> |
EmbeddedPythonWindowOperator is responsible for executing user defined python
ProcessWindowFunction in embedded Python environment. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.