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-5954) Always assign names to the window in the Stream SQL API
Date Fri, 03 Mar 2017 07:55:45 GMT

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

ASF GitHub Bot commented on FLINK-5954:

Github user sunjincheng121 commented on the issue:

    HI, @haohu thanks for your contribution!
    Can you tell me why we need this change? and can you add simple unit test ?

> Always assign names to the window in the Stream SQL API
> -------------------------------------------------------
>                 Key: FLINK-5954
>                 URL: https://issues.apache.org/jira/browse/FLINK-5954
>             Project: Flink
>          Issue Type: Improvement
>            Reporter: Haohui Mai
>            Assignee: Haohui Mai
> CALCITE-1603 and CALCITE-1615 brings in supports for {{TUMBLE}}, {{HOP}}, {{SESSION}}
grouped windows, as well as the corresponding auxiliary functions that allow uses to query
the start and the end of the windows (e.g., {{TUMBLE_START()}} and {{TUMBLE_END()}} see http://calcite.apache.org/docs/stream.html
for more details).
> The goal of this jira is to add support for these auxiliary functions in Flink. Flink
already has runtime supports for them, as these functions are essential mapped to the {{WindowStart}}
and {{WindowEnd}} classes.
> To implement this feature in transformation, the transformation needs to recognize these
functions and map them to the {{WindowStart}} and {{WindowEnd}} classes.
> The problem is that both classes can only refer to the windows using alias. Therefore
this jira proposes to assign a unique name for each window to enable the transformation.

This message was sent by Atlassian JIRA

View raw message