flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-3174) Add merging WindowAssigner
Date Mon, 04 Apr 2016 16:38:25 GMT

    [ https://issues.apache.org/jira/browse/FLINK-3174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15224479#comment-15224479

ASF GitHub Bot commented on FLINK-3174:

Github user StephanEwen commented on the pull request:

    Concerning the removal of the non-keyed window operator: Does that mean that the user
functions now see the dummy key?

> Add merging WindowAssigner
> --------------------------
>                 Key: FLINK-3174
>                 URL: https://issues.apache.org/jira/browse/FLINK-3174
>             Project: Flink
>          Issue Type: Improvement
>          Components: Streaming
>            Reporter: Aljoscha Krettek
>            Assignee: Aljoscha Krettek
>             Fix For: 1.0.0
> We should add the possibility for WindowAssigners to merge windows. This will enable
Session windowing support, similar to how Google Cloud Dataflow supports.
> For session windows, each element would initially be assigned to its own window. When
triggering we check the windows and see if any can be merged. This way, elements with overlapping
session windows merge into one session.

This message was sent by Atlassian JIRA

View raw message