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, 10 Mar 2017 01:06:37 GMT

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

ASF GitHub Bot commented on FLINK-5954:
---------------------------------------

Github user sunjincheng121 commented on the issue:

    https://github.com/apache/flink/pull/3461
  
    Hi, @haohui Thanks for your explanation, and I'll  see the  detail in the FLINK-5954.
    Thanks,
    SunJincheng


> 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
(v6.3.15#6346)

Mime
View raw message