FusionInsight MRS Flink DataStream API读写Hudi实践

📝

内容提要

目前Hudi只支持FlinkSQL进行数据读写,但是在实际项目开发中一些客户存在使用Flink DataStream API读写Hudi的诉求。1.HoodiePipeline.java 将Hudi内核读写接口进行封装,提供Hudi DataStream API。1)HoodiePipeline.java ,该类将Hudi内核读写接口进行封装,提供Hudi DataStream...

🏷️

标签

➡️

继续阅读