flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Haohui Mai (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-5954) Always assign names to the window in the Stream SQL APi
Date Fri, 03 Mar 2017 01:38:45 GMT
Haohui Mai created FLINK-5954:

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