Flink Hudi Sample Program Development Roadmap

Typical Scenario Description

In this example, the job generates one data record per second, writes the data to the Hudi table, and reads and prints the data in the Hudi table.

Development Guideline

1. Write data to Hudi:
   1. Generate data through a random data generation class.
   2. Convert the generated data into DataStream<RowData>.
   3. Write data to the Hudi table.
2. Read data from Hudi:
   1. Read data from the Hudi table.
   2. Combine the read data into the JSON format and print the data.