flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jark Wu (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4692) Add tumbling and sliding group-windows for batch tables
Date Wed, 09 Nov 2016 08:58:58 GMT

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

Jark Wu commented on FLINK-4692:

Hi [~twalthr] [~fhueske], I have some problems with this issue. I know that the tumbling window
can be computed by applying a MapFunction that extracts the grouping key(s) for each row and
applying a regular groupBy aggregation on all keys. But it seems that the sliding window can't
be computed in this way. Because every row should be grouped into multiple windows.

One way come out in my mind is partitioning the table on the non-window grouping keys and
applying a groupReduce with a group sort on the window-key. This is very like the way of session
window for batch tables.

Do you have good ideas ?

> Add tumbling and sliding group-windows for batch tables
> -------------------------------------------------------
>                 Key: FLINK-4692
>                 URL: https://issues.apache.org/jira/browse/FLINK-4692
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Table API & SQL
>            Reporter: Timo Walther
> Add Tumble and Slide group-windows for batch tables as described in [FLIP-11|https://cwiki.apache.org/confluence/display/FLINK/FLIP-11%3A+Table+API+Stream+Aggregations].

This message was sent by Atlassian JIRA

View raw message