本文為您介紹Realtime ComputeFlink版支援的表類型的定義和連接器。
表類型的定義
阿里雲Realtime ComputeFlink版通過Flink SQL定義表對上下遊儲存進行映射或者使用Datastream API進行串連來實現讀寫。支援以下幾種Flink SQL表類型的定義:
源表:是資料流的入口,用於從外部系統(如 Kafka、MySQL CDC)持續讀取原始事件數目據。
維表:是用於補充資訊的參考表,通常通過 JOIN 為流資料關聯靜態或低頻更新的維度資訊(如使用者、商品資訊)。
結果表:是資料處理的出口,用於將計算後的結果(如彙總、關聯後的資料)寫入目標系統(如數倉、資料庫、訊息佇列)。
支援的連接器
關係型資料庫 | NoSQL資料庫 | 訊息佇列 |
資料倉儲 | 資料湖 | 日誌/Object Storage Service服務 |
工具調試類 | 索引值/時序資料庫 | 通用類 |
連接器支援情況
連接器 | 支援類型 | 運行模式 | API類型 | 是否支援更新或刪除結果表資料 | ||
源表 | 維表 | 結果表 | ||||
說明 支援串連RDS MySQL版、PolarDB MySQL版及自建MySQL。 | √ | √ | √ | 流模式 | SQL、DataStream和資料攝入YAML | 是 |
√ | √ | √ | 流模式和批模式 | SQL、DataStream和資料攝入YAML | 是 | |
√ | × | √ | 流模式 | SQL、DataStream和資料攝入YAML | 不支援更新和刪除結果表資料,只支援插入資料。 | |
√ | √ | √ | 流模式和批模式 | SQL和DataStream | 不支援更新和刪除結果表資料,只支援插入資料。 | |
√ | √ | √ | 流模式和批模式 | SQL和資料攝入YAML | 是 | |
√ | × | √ | 流模式 | SQL和DataStream | 不支援更新和刪除結果表資料,只支援插入資料。 | |
√ | √ | √ | 流模式和批模式 | SQL、DataStream和資料攝入YAML | 是 | |
√ | × | √ | 流模式和批模式 | SQL和DataStream | 不支援更新和刪除結果表資料,只支援插入資料。 | |
√ | √ | √ | 流模式 | SQL和DataStream | 是 | |
√ | √ | √ | 流模式和批模式 | SQL | 是 | |
√ | × | √ | 流模式和批模式 | SQL和DataStream | 不支援更新和刪除結果表資料,只支援插入資料。 | |
說明 後續將不再支援雲資料庫RDS MySQL版連接器,建議您直接使用MySQL連接器。 | × | √ | √ | 流模式和批模式 | SQL | 是 |
√ | × | √ | 流模式 | SQL和DataStream | 不支援更新和刪除結果表資料,只支援插入資料。 | |
× | √ | √ | 流模式 | SQL | 是 | |
× | √ | √ | 流模式 | SQL | 是 | |
× | × | √ | 流模式 | SQL | 是 | |
× | √ | √ | 流模式 | SQL | 是 | |
√ | √ | √ | 流模式和批模式 | SQL | 是 | |
× | √ | √ | 流模式和批模式 | SQL | 是 | |
× | × | √ | 流模式和批模式 | SQL | 是 | |
√ | × | √ | 流模式 | SQL和資料攝入YAML | 是 | |
√ | √ | √ | 流模式和批模式 | SQL和DataStream | 是 | |
× | × | √ | 流模式和批模式 | SQL | 是 | |
√ | √ | √ | 流模式 | SQL | 是 | |
× | × | √ | 流模式和批模式 | DataStream和SQL | 是 | |
× | × | √ | 流模式 | SQL | 否 | |
√ | × | × | 流模式 | SQL | 不涉及 | |
√ | √ | √ | 流模式和批模式 | SQL | 是 | |
√ | × | √ | 流模式和批模式 | SQL | 是 | |
√ | √ | × | 流模式和批模式 | SQL | 不涉及 | |
× | × | √ | 流模式和批模式 | SQL | 是 | |
√ | × | × | 流模式和批模式 | SQL | 不涉及 | |
× | × | √ | 流模式和批模式 | SQL和資料攝入YAML | 是 | |
√ | × | √ | 流模式和批模式 | SQL和DataStream | 是 | |