@Override
    public RowData[] createBatch(int batchSize) {
        RowData[] arr = new RowData[batchSize];
        for (int i = 0; i < batchSize; ++i) {
            arr[i] = new RecyclableJoinedRowData(rowType.getFieldCount(), metadataConverters.length);
        }
        return arr;
    }
Copy from iceberg-flink:iceberg-flink-1.15:1.3.1
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/source/reader/RowDataRecordFactory.java