Package | Description |
---|---|
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.operators.source |
Modifier and Type | Class and Description |
---|---|
class |
SourceOperator<OUT,SplitT extends SourceSplit>
Base source operator only used for integrating the source reader which is proposed by FLIP-27.
|
Modifier and Type | Method and Description |
---|---|
ReaderOutput<T> |
TimestampsAndWatermarks.createMainOutput(PushingAsyncDataInput.DataOutput<T> output,
TimestampsAndWatermarks.WatermarkUpdateListener watermarkCallback)
Creates the ReaderOutput for the source reader, than internally runs the timestamp extraction
and watermark generation.
|
ReaderOutput<T> |
NoOpTimestampsAndWatermarks.createMainOutput(PushingAsyncDataInput.DataOutput<T> output,
TimestampsAndWatermarks.WatermarkUpdateListener watermarkEmitted) |
ReaderOutput<T> |
ProgressiveTimestampsAndWatermarks.createMainOutput(PushingAsyncDataInput.DataOutput<T> output,
TimestampsAndWatermarks.WatermarkUpdateListener watermarkEmitted) |
Constructor and Description |
---|
WatermarkToDataOutput(PushingAsyncDataInput.DataOutput<?> output,
TimestampsAndWatermarks.WatermarkUpdateListener watermarkEmitted)
Creates a new WatermarkOutput against the given DataOutput.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.