void set(DataIterator dataIterator) {
    if (dataIterator instanceof ChangeLogDataIterator) {
      ChangeLogDataIterator changelog = (ChangeLogDataIterator) dataIterator;
      currentInsertFileOffset = changelog.insertFileOffset();
      currentInsertRecordOffset = changelog.insertRecordOffset();
      currentDeleteFileOffset = changelog.deleteFileOffset();
      currentDeleteRecordOffset = changelog.deleteRecordOffset();
    } else {
      currentInsertFileOffset = dataIterator.fileOffset();
      currentInsertRecordOffset = dataIterator.recordOffset();
    }
  }
This class contains the file offset and record offset with actual record.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/hybrid/reader/RecordPosition.java