[FLINK-3643] Improve Windowing

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Component/s: API / DataStream
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 21/Mar/16 16:37
• Updated: 28/Feb/19 11:14
• Resolved: 30/Jan/17 15:18

Description

I think there are several shortcomings in the current window system and I started a document to keep track of them: https://docs.google.com/document/d/1Xp-YBf87vLTduYSivgqWVEMjYUmkA-hyb4muX3KRl08/edit?usp=sharing

The document is work-in-progress and I encourage everyone to read it and make suggestions:

We'll keep this issue to keep track of any sub-issues that we open for parts that we want to improve.

Issue Links

• contains: FLINK-2870 Add support for accumulating/discarding for Event-Time Windows
• contains: FLINK-3399 Count with timeout trigger
• links to: Window Trigger Design Doc

Sub-Tasks

• Use Processing-Time Clock in Window Assigners/Triggers: Closed
• Change StreamSource to use Processing-Time Clock Service: Closed
• Introduce Trigger Test Harness: Closed
• Add Support for "Allowed Lateness": Closed
• Update Windowing Documentation: Resolved
• Enhance Window Evictor: Closed
• Set Default Allowed Lateness to Zero and Make Triggers Non-Purging: Closed
• Enhance Trigger Interface with onFire(): Closed