全部產品
Search
文件中心

Realtime Compute for Apache Flink:Flink CDC資料攝入作業開發參考

更新時間:Jul 26, 2025

資料攝入是基於Flink CDC實現的、通過開發YAML作業的形式將資料從源端同步到目標端的一站式資料同步架構,實現從異構資料來源端到資料目標端的精準高效同步,提供毫秒級延遲的全增量一體化接入能力,在零代碼開發前提下滿足即時資料同步、即時數倉構建、流式湖倉構建等情境需求。

本文將從以下方面,向您介紹開發Flink CDC資料攝入作業所需的基本概念與配置參數。

功能說明

文檔

Flink CDC資料攝入工作群組成結構

Flink CDC作業結構

資料來源和目標端配置

Source和Sink模組

資料的處理與轉換方式

Transform模組

資料流向規則配置

Route模組

作業全域配置

Flink CDC Pipeline模組

表結構變更同步配置

Flink CDC表結構變更同步配置

內建函數

Flink CDC內建函數

自訂函數

Flink CDC自訂函數