flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Yuhong Hong (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-5584) Support Sliding-count row-window on streaming sql
Date Fri, 20 Jan 2017 01:44:26 GMT
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

View raw message