[FLINK-12185] Add support for generating optimized logical plan for join on stream

• 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: 13/Apr/19 11:03
• Updated: 17/Apr/19 03:30
• Resolved: 17/Apr/19 03:30

Description

This issue aims to supports generating optimized plan for join on stream.
The query will be converted to window join if join condition contains window bounds, otherwise will be converted to normal join.

e.g.
Queries similar to the following should be window join:

SELECT t1.a, t2.b FROM MyTable t1 JOIN MyTable2 t2 ON
    t1.a = t2.a AND
    t1.proctime BETWEEN t2.proctime - INTERVAL '1' HOUR AND t2.proctime + INTERVAL '1' HOUR

Issue Links

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