Aljoscha Krettek created FLINK-2870:
---------------------------------------
Summary: Add support for accumulating/discarding for Event-Time Windows
Key: FLINK-2870
URL:
https://issues.apache.org/jira/browse/FLINK-2870 Project: Flink
Issue Type: Sub-task
Components: Streaming
Reporter: Aljoscha Krettek
Assignee: Aljoscha Krettek
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.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)