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...
➡️