@Override
        public RowData add(RowData row) {
            partitionKey.partition(lazyRowDataWrapper().wrap(row));
            allPartition.add(partitionKey.toPath());

            return ((KVBuffer<Tuple2<String, Long>, RowData>) buffer).put(
                    new Tuple2<>(partitionKey.toPath(), number.incrementAndGet()), row);
        }
Initialize {@link NonPreAggPartitionGroupBuffer}

@param rowSchema row data schema
@param partitionKey partition key
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/collections/PartitionGroupBuffer.java