本文要演示的是：使用 Temporal Table DDL 定義被關(guān)聯(lián)表（維表），然后基于主動(dòng)關(guān)聯(lián)表（事實(shí)表）的“處理時(shí)間”去進(jìn)行Temporal Join（關(guān)聯(lián)時(shí)間維度上對(duì)應(yīng)版本的維表數(shù)據(jù)）。該演示涉及三個(gè)要點(diǎn)：

• 被關(guān)聯(lián)的表（維表）是用 Temporal Table DDL 形式定義，必須是一張時(shí)態(tài)表（版本表）
• 主動(dòng)關(guān)聯(lián)的表（事實(shí)表）需要定義“處理時(shí)間”屬性，但并不需要是一張時(shí)態(tài)表（版本表）
• Temporal Join 是使用 Temporal Table DDL + FOR SYSTEM_TIME AS OF 關(guān)鍵字實(shí)現(xiàn)的

測試結(jié)果會(huì)報(bào)如下錯(cuò)誤：

[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.TableException: Processing-time temporal join is not supported yet.

文檔所述一致，即：Flink 不支持使用 Temporal Table DDL 實(shí)現(xiàn)基于處理時(shí)間的 Temporal Join！此經(jīng)該功能是支持的是，后因 FLINK-19830 描述的問題而在新版本中被禁止使用了。

-- 事實(shí)表: transactionsdrop table