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 17:04:25 GMT

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

ASF GitHub Bot commented on FLINK-3174:

Github user aljoscha commented on the pull request:

    No, we introduced the `InternalWindowFunction` before 1.0.0 to decouple the user `WindowFunction`
from the window operator implementation. There are now special `InternalWindowFunctions` that
don't forward the key to the user function. The API for the user does not change, there an
`AllWindowFunction` is used, as before. And that function does not get a 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