[FLINK-12345] Add support for generating optimized logical plan for stream window aggregate

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: godfrey he
• Reporter: godfrey he
• Created: 27/Apr/19 12:11
• Updated: 07/May/19 14:08
• Resolved: 07/May/19 14:08

Description

This issue aims to add support for generating optimized logical plan for stream window aggregate queries, e.g.

SELECT COUNT(*),
    TUMBLE_END(rowtime, INTERVAL '15' MINUTE) + INTERVAL '1' MINUTE
FROM MyTable
    GROUP BY TUMBLE(rowtime, INTERVAL '15' MINUTE)

the above query will be optimized to following plan

Calc(select=[EXPR$0, +(CAST(w$end), 60000:INTERVAL MINUTE) AS EXPR$1])
+- GroupWindowAggregate(window=[TumblingGroupWindow], properties=[w$start, w$end, w$rowtime], select=[COUNT(*) AS EXPR$0, start('w$) AS w$start, end('w$) AS w$end, rowtime('w$) AS w$rowtime])
   +- Exchange(distribution=[single])
      +- Calc(select=[rowtime])
         +- DataStreamScan(table=[[_DataStreamTable_0]], fields=[a, b, c, proctime, rowtime])

Issue Links

• is a child of: FLINK-11488 Add a basic Blink planner framework
• links to: GitHub Pull Request #8288