private SingleOutputStreamOperator<Void> appendCommitter(
                SingleOutputStreamOperator<WriteResult> writerStream) {
            IcebergFilesCommitter filesCommitter =
                    new IcebergFilesCommitter(
                            tableLoader,
                            flinkWriteConf.overwriteMode(),
                            snapshotProperties,
                            flinkWriteConf.workerPoolSize(),
                            flinkWriteConf.branch(),
                            table.spec());
            SingleOutputStreamOperator<Void> committerStream =
                    writerStream
                            .transform(operatorName(ICEBERG_FILES_COMMITTER_NAME), Types.VOID, filesCommitter)
                            .setParallelism(1)
                            .setMaxParallelism(1);
            if (uidPrefix != null) {
                committerStream = committerStream.uid(uidPrefix + "-committer");
            }
            return committerStream;
        }
Append the iceberg sink operators to write records to iceberg table.

@return {@link DataStreamSink} for sink.
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/FlinkSink.java