[FLINK-19073] Improve streamExecTemporalJoinRule

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Resolved
• Component/s: Table SQL / Planner
• Assignee: Leonard Xu
• Reporter: Leonard Xu
• Created: 28/Aug/20 03:38
• Updated: 16/Oct/20 15:49
• Resolved: 16/Oct/20 15:49

Description

Improve streamExecTemporalJoinRule that matches a temporal join node and converts it to [[StreamExecTemporalJoin]],

the temporal join node is a [[FlinkLogicalJoin]] whose left input is a [[FlinkLogicalRel]] and right input is a [[FlinkLogicalSnapshot]].

Issue Links

• links to: https://github.com/apache/flink/pull/13299