package timestamp
Type Members
-
class
BoundedOutOfOrderPreviousElementAssigner[T] extends AssignerWithPeriodicWatermarks[T] with Serializable
It is a copy-paste of BoundedOutOfOrdernessTimestampExtractor but taking timestamp from previousElementTimestamp See https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#using-kafka-timestamps-and-flink-event-time-in-kafka-010
It is a copy-paste of BoundedOutOfOrdernessTimestampExtractor but taking timestamp from previousElementTimestamp See https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#using-kafka-timestamps-and-flink-event-time-in-kafka-010
- Annotations
- @silent( "deprecated" ) @nowarn( "cat=deprecation" )
-
abstract
class
BoundedOutOfOrdernessPunctuatedExtractor[T] extends AssignerWithPunctuatedWatermarks[T]
- Annotations
- @silent( "deprecated" ) @nowarn( "cat=deprecation" )
- class TimestampAssignmentHelper[T] extends AnyRef