paimon
paimon copied to clipboard
[FLINK-31434] Introduce CDC sink
Purpose
To directly consume changes from Flink CDC connectors, we need a special CDC sink for Paimon.
Tests
- FlinkCdcSinkITCase
API and Format
N/A
Documentation
N/A