Jark Wu created FLINK-12269:
-------------------------------
Summary: Support Temporal Table Join in blink planner
Key: FLINK-12269
URL: https://issues.apache.org/jira/browse/FLINK-12269
Project: Flink
Issue Type: New Feature
Components: Table SQL / Planner
Reporter: Jark Wu
Support translate following "FOR SYSTEM_TIME AS OF" query into
{{StreamExecTemporalTableJoin}}.
{code:sql}
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
{code}
This is an extension to current temporal join (FLINK-9738) using a standard
syntax introduced in Calcite 1.19.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
