flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-5584) Support Sliding-count row-window on streaming sql
Date Fri, 03 Mar 2017 03:29:46 GMT

    [ https://issues.apache.org/jira/browse/FLINK-5584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15893670#comment-15893670

ASF GitHub Bot commented on FLINK-5584:

Github user hongyuhong closed the pull request at:


> 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
>            Assignee: 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