Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Duplicate
-
None
-
None
-
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
- Is contained by
-
FLINK-3643 Improve Windowing
- Closed
- is related to
-
FLINK-3177 Add Stream Operator that Discards Late Elements
- Closed