Modifier and Type | Method and Description |
---|---|
OneInputOperatorTransformation<T> |
OneInputOperatorTransformation.assignTimestamps(TimestampAssigner<T> assigner)
Deprecated.
Assigns an event time timestamp to each record.
|
Constructor and Description |
---|
TimestampAssignerWrapper(TimestampAssigner<T> assigner)
Deprecated.
|
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. |
Modifier and Type | Class and Description |
---|---|
class |
PeriodicWatermarkAssignerWrapper
Generates periodic watermarks based on a
PeriodicWatermarkAssigner . |
class |
PunctuatedWatermarkAssignerWrapper
Generates periodic watermarks based on a
PunctuatedWatermarkAssigner . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.