Modifier and Type | Method and Description |
---|---|
SingleOutputStreamOperator<T> |
DataStream.assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks<T> timestampAndWatermarkAssigner)
Deprecated.
Please use
DataStream.assignTimestampsAndWatermarks(WatermarkStrategy) instead. |
Modifier and Type | Class and Description |
---|---|
class |
IngestionTimeExtractor<T>
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
AscendingTimestampExtractor<T>
Deprecated.
|
class |
BoundedOutOfOrdernessTimestampExtractor<T>
This is a
AssignerWithPeriodicWatermarks used to emit Watermarks that lag behind the
element with the maximum timestamp (in event time) seen so far by a fixed amount of time,
t_late . |
Modifier and Type | Method and Description |
---|---|
FlinkKafkaConsumerBase<T> |
FlinkKafkaConsumerBase.assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks<T> assigner)
Deprecated.
Please use
FlinkKafkaConsumerBase.assignTimestampsAndWatermarks(WatermarkStrategy) instead. |
Modifier and Type | Method and Description |
---|---|
AssignerWithPeriodicWatermarks<T> |
FlinkKinesisConsumer.getPeriodicWatermarkAssigner() |
Modifier and Type | Method and Description |
---|---|
void |
FlinkKinesisConsumer.setPeriodicWatermarkAssigner(AssignerWithPeriodicWatermarks<T> periodicWatermarkAssigner)
Set the assigner that will extract the timestamp from
T and calculate the watermark. |
Modifier and Type | Class and Description |
---|---|
class |
CustomWatermarkExtractor
A custom
AssignerWithPeriodicWatermarks , that simply assumes that the input stream
records are strictly ascending. |
Constructor and Description |
---|
AssignerWithPeriodicWatermarksAdapter(AssignerWithPeriodicWatermarks<T> wms) |
Strategy(AssignerWithPeriodicWatermarks<T> wms) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.