flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2870) Add support for accumulating/discarding for Event-Time Windows
Date Mon, 19 Oct 2015 14:57:05 GMT
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)

Mime
View raw message