Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-3957 Breaking changes for Flink 2.0
  3. FLINK-4367

Offer separate API for watermark generation and timestamp extraction

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.1.0
    • 2.0.0
    • API / DataStream
    • 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.

      Attachments

        Activity

          People

            Unassigned Unassigned
            rmetzger Robert Metzger
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated: