[
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
(v6.3.4#6332)
