Details
-
Sub-task
-
Status: Open
-
Major
-
Resolution: Unresolved
-
1.1.0
-
None
Description
Right now, the AssignerWithPunctuatedWatermarks and AssignerWithPeriodicWatermarks interfaces also require implementing a TimestampAssigner.
For cases where the source emits records with timestamps, its not necessary to extract timestamps again from the records, we just want to generate watermarks.