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

Add a general-purpose keyed-window operator

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.10.0
    • 0.10.0
    • API / DataStream
    • None

    Description

      This operator should support:

      • Customizable triggers
      • Eviction on triggers: all / none / custom
      • Discard by time (expiry of state)
      • Event time time window assignment

      This set of requirements is effectively a mix between the current trigger/evict model and the Cloud Dataflow window definition model.

      Attachments

        Issue Links

          Activity

            People

              aljoscha Aljoscha Krettek
              sewen Stephan Ewen
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: