paimon
paimon copied to clipboard
[flink] Support cdc source
Purpose
This PR adds support to use Paimon as a Flink CDC Pipeline Source.
Tests
Tests are added to the org.apache.paimon.flink.pipeline.cdc.source package of paimon-flink-cdc module to verify its correctness
API and Format
It changes the API by adding a new Flink source implementation.
Documentation
It introduces new features that are documented in docs/content/cdc-ingestion/flink-cdc-paimon-pipeline-connector.md.