hudi connector用flink cdc的pipeline配置文件方式提交的话，要怎么改造?

你好，你最终实现了吗？可以分享下具体改造流程吗？

要使用Flink CDC的pipeline配置文件方式提交Hudi连接器，你需要进行以下步骤：

1. 定义Hudi Sink: 在Flink的conf/flink-conf.yaml文件中，添加Hudi的配置信息。这包括指定Hudi的存储类型（例如，COW或MOR），表名，以及其他相关配置。

2. 创建源表和目标表: 使用Flink SQL DDL语句创建源表（从MySQL CDC捕获变更）和目标表（将变更写入到Hudi）。

3. 编写SQL查询: 使用Flink SQL编写一个查询，该查询将从源表中读取变更，并将结果插入到目标表中。

4. 创建pipeline配置文件: 创建一个Flink pipeline配置文件，该文件包含上述SQL查询以及所需的连接器配置。

5. 提交作业: 使用Flink的客户端工具提交作业，指定pipeline配置文件作为参数。

请注意，虽然Flink CDC提供了对Hudi的支持，但是目前还没有直接继承Sink接口的Hudi连接器，因此可能需要自定义一个继承Sink接口的适配器类来实现适配。具体步骤可以参考Flink CDC的文档和示例代码。