[ https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15850641#comment-15850641 ]
ASF GitHub Bot commented on FLINK-5624: --------------------------------------- Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3252 Hi @haohui, thanks for your contribution! The referenced JIRA is about adding support for group windows to SQL, not OVER (or row) windows. It should enable queries such as: ``` SELECT a, sum(b) as sumB, TUMBLE_END(rowtime(), INTERVAL '1' HOUR) AS t, FROM myT GROUP BY TUMBLE(rowtime(), INTERVAL '1' HOUR), a; ``` I saw that you contributed `TUMBLE` just very recently to Calcite, so this feature is not yet available in a Calcite release that we could link against. Until then, we could add support for the more manual version of SQL tumbling windows: ``` SELECT a, SUM(b) AS sumB, CEIL(rowtime() TO HOUR) AS t, FROM myT GROUP BY CEIL(rowtime() TO HOUR), a ``` We would also need to find a way to reference the `rowtime`. We do not want to expose this as an actual attribute in Flink's SQL (internally, Flink treats record timestamps as metadata which may not be modified by a query). The current approach would be to implement a built-in function which serves as a marker and is replaced during the translation. Best, Fabian > Support tumbling window on streaming tables in the SQL API > ---------------------------------------------------------- > > Key: FLINK-5624 > URL: https://issues.apache.org/jira/browse/FLINK-5624 > Project: Flink > Issue Type: Bug > Components: Table API & SQL > Reporter: Haohui Mai > Assignee: Haohui Mai > > This is a follow up of FLINK-4691. > FLINK-4691 adds supports for group-windows for streaming tables. This jira > proposes to expose the functionality in the SQL layer via the {{GROUP BY}} > clauses, as described in > http://calcite.apache.org/docs/stream.html#tumbling-windows. -- This message was sent by Atlassian JIRA (v6.3.15#6346)