Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-2674 Rework windowing logic
  3. FLINK-2870

Add support for accumulating/discarding for Event-Time Windows

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Duplicate
    • None
    • None
    • API / DataStream
    • None

    Description

      This would allow to specify whether windows should be discarded after the trigger fires or kept in the operator if late elements arrive.

      When keeping elements, the user would also have to specify an allowed lateness time after which the window contents are discarded without emitting any further window evaluation result.

      If elements arrive after the allowed lateness they would trigger the window immediately with only the one single element.

      Attachments

        Issue Links

          Activity

            People

              aljoscha Aljoscha Krettek
              aljoscha Aljoscha Krettek
              Votes:
              1 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: