[FLINK-19072] Import Temporal Table join rule

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Done
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: Leonard Xu
• Reporter: Leonard Xu
• Created: 28/Aug/20 03:37
• Updated: 16/Oct/20 15:09
• Resolved: 16/Oct/20 15:06

Description

The initial temporal table join (FOR SYSTEM_TIME AS OF) is a Correlate, we need rewrite it into a Join to make join condition can be pushed-down. The join will be translated into  [[StreamExecLookupJoin]]  or  [[StreamExecTemporalJoin]] in physical. 

Import  Temporal table join rule to deal above temporal join rewrite logic.

Issue Links

• links to: GitHub Pull Request #13299