[jira] [Created] (FLINK-5584) Support Sliding-count row-window on streaming sql

["Yuhong Hong (JIRA)" <ji...@apache.org>]

Yuhong Hong created FLINK-5584:
----------------------------------

             Summary: 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)