資料攝入是基於Flink CDC實現的、通過開發YAML作業的形式將資料從源端同步到目標端的一站式資料同步架構,實現從異構資料來源端到資料目標端的精準高效同步,提供毫秒級延遲的全增量一體化接入能力,在零代碼開發前提下滿足即時資料同步、即時數倉構建、流式湖倉構建等情境需求。
本文將從以下方面,向您介紹開發Flink CDC資料攝入作業所需的基本概念與配置參數。
功能說明 | 文檔 |
Flink CDC資料攝入工作群組成結構 | |
資料來源和目標端配置 | |
資料的處理與轉換方式 | |
資料流向規則配置 | |
作業全域配置 | |
表結構變更同步配置 | |
內建函數 | |
自訂函數 |