流数据湖平台Apache Paimon（二）集成 Flink 引擎

SNAPSHOT.jar \ mysql-sync-table –warehouse \ –database \ –table \ [–partition-keys ] \ [–primary-keys ] \ [–computed-column <‘column-name=expr-name(args[, …])’> [–computed-column …]] \ [–mysql-conf [–mysql-conf …]] \ [–catalog-conf –computed-column 计算列的定义。参数字段来自 MySQL 表字段名称。 –mysql-conf Flink CDC MySQL 源表的配置。 <‘column-name=expr-name(args[, …])’> [–computed-column …]] \ [–kafka-conf [–kafka-conf …]] \ [–catalog-conf –computed-column 计算列的定义。参数字段来自 Kafka 主题的表字段名称。 –kafka-conf Flink Kafka 源的配置。