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