更新时间:2024-08-03 GMT+08:00
Flink Hudi样例程序开发思路
本章节适用于MRS 3.3.0及以后版本。
典型场景说明
本样例中Job每秒生成1条数据,将数据写入到Hudi表中,再读取并打印Hudi表中的数据。
开发思路
- 写Hudi:
- 通过一个随机生成数据类来生成数据。
- 将生成的数据转化为DataStream<RowData>。
- 将数据写入到Hudi表中。
- 读Hudi:
- 读取Hudi表中的数据。
- 将读取的数据拼接成json格式并打印。
父主题: Flink读取Hudi表样例程序