Package | Description |
---|---|
org.apache.flink.streaming.api.operators.python |
Modifier and Type | Class and Description |
---|---|
class |
PythonFlatMapOperator<IN,OUT>
The
PythonFlatMapOperator is responsible for executing Python functions that gets one
input and produces zero/one or more outputs. |
class |
PythonMapOperator<IN,OUT>
The
PythonMapOperator is responsible for executing Python functions that gets one input
and produces zero/one or more outputs. |
class |
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. |
class |
PythonProcessOperator<IN,OUT>
PythonProcessOperator is responsible for launching beam runner which will start a python
harness to execute user defined python ProcessFunction. |
class |
PythonReduceOperator<OUT>
PythonReduceOperator is responsible for launching beam runner which will start a python
harness to execute user defined python ReduceFunction. |
class |
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.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.