public static DataStream<HoodieRecord> rowDataToHoodieRecord(Configuration conf, RowType rowType,
            DataStream<RowData> dataStream) {
        return dataStream.map(RowDataToHoodieFunctions.create(rowType, conf), TypeInformation.of(HoodieRecord.class))
                .setParallelism(dataStream.getParallelism()).name("row_data_to_hoodie_record");
    }
Transforms the row data to hoodie records.
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hudi/src/main/java/org/apache/inlong/sort/hudi/sink/utils/Pipelines.java