[FLINK-5954] Always assign names to the window in the Stream SQL API

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.3.0
• Assignee: Haohui Mai
• Reporter: Haohui Mai
• Created: 03/Mar/17 01:38
• Updated: 10/Mar/17 23:32
• Resolved: 10/Mar/17 23:32

Description

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.

Issue Links

• links to: GitHub Pull Request #3461