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)

Reply via email to