[
https://issues.apache.org/jira/browse/FLINK-5584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15833018#comment-15833018
]
ASF GitHub Bot commented on FLINK-5584:
---------------------------------------
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3175
Hi @hongyuhong , don't worry about that. Very welcome to contribute to
Flink. And please feel free to contact us if you have any question!
> Support Sliding-count row-window on streaming sql
> -------------------------------------------------
>
> Key: FLINK-5584
> URL: https://issues.apache.org/jira/browse/FLINK-5584
> Project: Flink
> Issue Type: New Feature
> Components: Table API & SQL
> Reporter: Yuhong Hong
>
> Calcite has already support sliding-count row-window, the grammar look like:
> select sum(amount) over (rows 10 preceding) from Order;
> select sum(amount) over (partition by user rows 10 preceding) from Order;
> And it will parse the sql as a LogicalWindow relnode, the logical Window
> contains aggregate func info and window info, it's similar to Flink
> LogicalWIndowAggregate, so we can add an convert rule to directly convert
> LogicalWindow into DataStreamAggregate relnode, and if Calcite support more
> grammar, we can extend the convert rule.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
