更新时间:2024-08-03 GMT+08:00

Flink Hudi样例程序开发思路

本章节适用于MRS 3.3.0及以后版本。

典型场景说明

本样例中Job每秒生成1条数据,将数据写入到Hudi表中,再读取并打印Hudi表中的数据。

开发思路

  1. 写Hudi:
    1. 通过一个随机生成数据类来生成数据。
    2. 将生成的数据转化为DataStream<RowData>。
    3. 将数据写入到Hudi表中。
  2. 读Hudi:
    1. 读取Hudi表中的数据。
    2. 将读取的数据拼接成json格式并打印。