CDC集成
paimon支持五种方式通过模式转化数据提取到paimon表中。添加的列会实时同步到Paimon表中
- MySQL同步表：将MySQL中的一张或多张表同步到一张Paimon表中。
- MySQL同步数据库：将MySQL的整个数据库同步到一个Paimon数据库中。
- API同步表：将您的自定义DataStream输入同步到一张Paimon表中。
- Kafka同步表：将一个Kafka topic的表同步到一张Paimon表中。
- Kafka同步数据库：将一个包含多表的Kafka主题或多个各包含一表的主题同步到一个Paimon数据库中。
1、Mysql同步
准备：必须添加FlinkCDC连接器
cp flink-sql-connector-mysql-cdc-3.0.1.jar /opt/module/flink-1.18.0/lib,重启yarn-session集群和sql-client。重启yarn-session集群和sql-client。
1.1同步表
1）语法说明
<
)