[FLINK-3581] Add Special Aligned Event-Time WindowOperator

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Component/s: API / DataStream
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 04/Mar/16 14:08
• Updated: 02/Oct/19 17:43
• Resolved: 07/May/17 07:19

Description

The current Window Trigger is per key. Meaning every window has a (logical) Trigger for every key in the window, i.e. there will be state and time triggers per key per window.

For some types of windows, i.e. based on time it is possible to use a single Trigger to fire for all keys at the same time. In that case we would save a lot of space on state and timers. Which makes state snapshots a lot smaller.

Issue Links

• duplicates: FLINK-3370 Add an aligned version of the window operator

Sub-Tasks

• Add Iterator over State for All Keys in Partitioned State: Closed