[FLINK-12269] Support Temporal Table Join in blink planner

• 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: Jark Wu
• Reporter: Jark Wu
• Created: 20/Apr/19 03:22
• Updated: 08/Aug/19 13:10
• Resolved: 13/May/19 09:44

Description

Support translate following "FOR SYSTEM_TIME AS OF" query into StreamExecTemporalTableJoin.

SELECT
  o.amout, o.currency, r.rate, o.amount * r.rate
FROM
  Orders AS o
  JOIN LatestRates FOR SYSTEM_TIME AS OF o.proctime AS r
  ON r.currency = o.currency

This is an extension to current temporal join (FLINK-9738) using a standard syntax introduced in Calcite 1.19.

Issue Links

• contains: FLINK-11840 Introduce FlinkLogicalSnapshot
• duplicates: FLINK-12025 Support FOR SYSTEM_TIME AS OF in temporal table
• is a child of: FLINK-11488 Add a basic Blink planner framework
• links to: GitHub Pull Request #8302