public List<HoodieRecord> writeBuffer() {
            // rewrite all the records with new record key
            return records.stream()
                    .map(record -> record.toHoodieRecord(partitionPath))
                    .collect(Collectors.toList());
        }
Prepare the write data buffer: patch up all the records with correct partition path.
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hudi/src/main/java/org/apache/inlong/sort/hudi/sink/StreamWriteFunction.java