Package | Description |
---|---|
org.apache.flink.streaming.api.operators.python |
Modifier and Type | Class and Description |
---|---|
class |
AbstractOneInputPythonFunctionOperator<IN,OUT>
AbstractOneInputPythonFunctionOperator is responsible for launching beam runner which
will start a python harness to execute user defined python function. |
class |
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. |
class |
PythonBatchCoBroadcastProcessOperator<IN1,IN2,OUT>
The
PythonBatchCoBroadcastProcessOperator is responsible for executing the Python
CoBroadcastProcess Function under BATCH mode, PythonCoProcessOperator is used under
STREAMING mode. |
class |
PythonBatchKeyedCoBroadcastProcessOperator<OUT>
The
PythonBatchKeyedCoBroadcastProcessOperator is responsible for executing the Python
CoBroadcastProcess function under BATCH mode, PythonKeyedCoProcessOperator is used under
STREAMING mode. |
class |
PythonCoProcessOperator<IN1,IN2,OUT>
The
PythonCoProcessOperator is responsible for executing the Python CoProcess Function. |
class |
PythonKeyedCoProcessOperator<OUT>
KeyedCoProcessOperator.
|
class |
PythonKeyedProcessOperator<OUT>
PythonKeyedProcessOperator is responsible for launching beam runner which will start a
python harness to execute user defined python function. |
class |
PythonProcessOperator<IN,OUT>
PythonProcessOperator is responsible for launching beam runner which will start a python
harness to execute user defined python ProcessFunction. |
Modifier and Type | Method and Description |
---|---|
<T> AbstractDataStreamPythonFunctionOperator<T> |
PythonKeyedCoProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
<T> AbstractDataStreamPythonFunctionOperator<T> |
PythonProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
<T> AbstractDataStreamPythonFunctionOperator<T> |
PythonKeyedProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
<T> AbstractDataStreamPythonFunctionOperator<T> |
PythonCoProcessOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
abstract <T> AbstractDataStreamPythonFunctionOperator<T> |
AbstractDataStreamPythonFunctionOperator.copy(DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeInformation<T> outputTypeInfo) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.