private void emit(WriteResult result) {
        LOGGER.debug("Emit iceberg write result dataFiles: {}, result.deleteFiles {}",
                result.dataFiles(), result.deleteFiles());
        collector.collect(result);
    }
check if the data is incremental phase
by checking the incremental field
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleStreamWriter.java