@Override
    public void initialize(int taskId, int attemptId) {
        this.outputFileFactory = OutputFileFactory.builderFor(table, taskId, attemptId).build();
    }
Copy from iceberg-flink:iceberg-flink-1.13:0.13.2
Add an option `sink.ignore.changelog` to support insert-only mode without equalityFieldIds.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/RowDataTaskWriterFactory.java