Modifier and Type | Method and Description |
---|---|
OneInputOperatorTransformation<T> |
OneInputOperatorTransformation.assignTimestamps(TimestampAssigner<T> assigner)
Assigns an event time timestamp to each record.
|
Constructor and Description |
---|
TimestampAssignerWrapper(TimestampAssigner<T> assigner) |
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–2022 The Apache Software Foundation. All rights reserved.