Package | Description |
---|---|
org.apache.flink.streaming.api.functions | |
org.apache.flink.streaming.api.functions.timestamps | |
org.apache.flink.streaming.kafka.test.base |
Modifier and Type | Interface and Description |
---|---|
interface |
AssignerWithPeriodicWatermarks<T>
Deprecated.
|
interface |
AssignerWithPunctuatedWatermarks<T>
Deprecated.
|
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 | Class and Description |
---|---|
class |
CustomWatermarkExtractor
A custom
AssignerWithPeriodicWatermarks , that simply assumes that the input stream
records are strictly ascending. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.