[
https://issues.apache.org/jira/browse/FLINK-5584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645907#comment-16645907
]
Hequn Cheng commented on FLINK-5584:
------------------------------------
I think this has been solved by
[FLINK-4557|https://issues.apache.org/jira/browse/FLINK-4557]. I will close
this one.
> 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: hongyuhong
> Assignee: hongyuhong
> Priority: Major
>
> 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
(v7.6.3#76005)
