请问各位大佬，flink mysql cdc2.3通过HoodiePipeline写hudi，因my

要实现Hudi动态建表，可以使用Hoodie提供的SchemaManager和FileSystemStateStore。

首先，在HoodiePipeline中创建一个SchemaManager对象，用于管理Hudi表的schema变化。当MySQL字段变更时，可以调用SchemaManager的updateSchema()方法来更新Hudi表的schema。这个方法会根据MySQL表中的变更数据生成一个新的Hudi表。

其次，需要使用Hoodie的FileSystemStateStore来管理Hudi表的状态。在HoodiePipeline中创建一个StateStoreFactory对象，用于获取FileSystemStateStore对象。然后，将Hudi表的元数据(包括表名、分区键、列族等)存储在StateStore中。这样，当MySQL字段变更时，可以从StateStore中读取旧的Hudi表元数据，然后使用新的元数据来创建一个新的Hudi表。

最后，在HoodiePipeline中创建一个HudiWriter对象，用于将Hoodie表中的数据写入HDFS或云存储中。当MySQL字段变更时，可以调用HudiWriter的commit()方法来提交Hudi表中的更改。如果没有提交，那么下一次执行任务时会重新创建一个新的Hudi表。

总之，通过使用SchemaManager和FileSystemStateStore,可以在HoodiePipeline中实现动态建表的功能。当MySQL字段变更时，可以根据变更数据生成新的Hudi表，并将旧的元数据存储在StateStore中。这样就可以避免重复创建Hudi表的问题，提高数据处理效率。