Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-3581 Add Special Aligned Event-Time WindowOperator
  3. FLINK-3582

Add Iterator over State for All Keys in Partitioned State

    XMLWordPrintableJSON

Details

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

    Description

      Having a non-keyed trigger requires that we have a way to iterate over the state for all keys, so that we can emit window results.

      This should only be for internal use, but maybe users also want to iterate over the state for all keys.

      As a corollary, we then also need a way to drop state for all keys at the same time.

      Attachments

        Activity

          People

            aljoscha Aljoscha Krettek
            aljoscha Aljoscha Krettek
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: