流式数据湖平台实战 | 在Flink DataStream API中集成和使用Hudi

时间:2024-03-19 22:24:50

 1.Flink Datastream API中使用Hudi

添加相应版本的maven依赖

<!-- Flink 1.13 -->
<dependency>
    <groupId>org.apache.hudi</groupId>
    <artifactId>hudi-flink1.13-bundle</artifactId>
    <version>0.14.0</version>
</dependency>
<!-- Flink 1.14 -->
<dependency>
    <groupId>org.apache.hudi</groupId>
    <artifactId>hudi-flink1.14-bundle</artifactId>
    <version>0.14.0</version>
</dependency>
<!-- Flink 1.15 -->
<dependency>
    <groupId>org.apache.hudi</groupId>
    <artifactId>hudi-flink1.15-bundle</artifactId>
    <version>0.14.0</version>
</dependency>
<!-- Flink 1.16 -->
<dependency>
    <groupId>org.apache.hudi</groupId>
    <artifactId>hudi-flink1.16-bundle</artifactId>
    <version>0.14.0</v