[FLINK-12170] Add support for generating optimized logical plan for Over 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: 12/Apr/19 09:38
• Updated: 17/Apr/19 11:50
• Resolved: 17/Apr/19 11:50

Description

This issue aims to generate optimized plan for Over aggregate queries on both Batch and Stream, e.g.

SELECT a, b, c, RANK() OVER (PARTITION BY b ORDER BY c) FROM MyTable

currently, Stream requires all over aggregate functions must be computed on the same window, e.g.

SELECT c,
    COUNT(a) OVER (PARTITION BY c ORDER BY proctime RANGE UNBOUNDED PRECEDING),
    SUM(a) OVER (PARTITION BY b ORDER BY proctime RANGE UNBOUNDED PRECEDING)
from MyTable

the above sql is not supported because the partition keys are different.

Batch does not have such limitation.

Issue Links

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