@Override
    public void emitRecord(
            RecordAndPosition<T> element, SourceOutput<T> output, IcebergSourceSplit split) {
        output.collect(element.record());
        split.updatePosition(element.fileOffset(), element.recordOffset());
    }
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/IcebergSourceRecordEmitter.java