文档首页/ MapReduce服务 MRS/ 开发指南（LTS版）/ Flink开发指南（普通模式）/ 开发Flink应用/ Flink读取Hudi表样例程序/ Flink Hudi样例程序开发思路
更新时间：2024-06-05 GMT+08:00
查看PDF
分享

Flink Hudi样例程序开发思路

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

典型场景说明

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

开发思路

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

相关文档