Class | Description |
---|---|
AbstractOneInputPythonFunctionOperator<IN,OUT> |
Base class for all one input stream operators to execute Python functions.
|
AbstractPythonFunctionOperator<OUT> |
Base class for all stream operators to execute Python functions.
|
AbstractTwoInputPythonFunctionOperator<IN1,IN2,OUT> |
Base class for all two input stream operators to execute Python functions.
|
OneInputPythonFunctionOperator<IN,OUT,UDFIN,UDFOUT> |
OneInputPythonFunctionOperator is responsible for launching beam runner which will start
a python harness to execute user defined python function. |
PythonCoFlatMapOperator<IN1,IN2,OUT> |
The
PythonCoFlatMapOperator is responsible for executing the Python CoMap Function. |
PythonCoMapOperator<IN1,IN2,OUT> |
The
PythonCoFlatMapOperator is responsible for executing the Python CoMap Function. |
PythonFlatMapOperator<IN,OUT> |
The
PythonFlatMapOperator is responsible for executing Python functions that gets one
input and produces zero/one or more outputs. |
PythonKeyedCoProcessOperator<OUT> |
KeyedCoProcessOperator.
|
PythonKeyedProcessOperator<OUT> |
PythonKeyedProcessOperator is responsible for launching beam runner which will start a
python harness to execute user defined python function. |
PythonMapOperator<IN,OUT> |
The
PythonMapOperator is responsible for executing Python functions that gets one input
and produces zero/one or more outputs. |
PythonPartitionCustomOperator<IN,OUT> |
The
PythonPartitionCustomOperator enables us to set the number of partitions for current
operator dynamically when generating the StreamGraph
before executing the job. |
PythonProcessOperator<IN,OUT> |
PythonProcessOperator is responsible for launching beam runner which will start a python
harness to execute user defined python ProcessFunction. |
PythonTimestampsAndWatermarksOperator<IN> |
A stream operator that may do one or both of the following: extract timestamps from events and
generate watermarks by user specify TimestampAssigner and WatermarkStrategy.
|
TwoInputPythonFunctionOperator<IN1,IN2,RUNNER_OUT,OUT> |
TwoInputPythonFunctionOperator is responsible for launching beam runner which will start
a python harness to execute two-input user defined python function. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.