public void asyncWrite(RowKind rowKind, byte[] keyBytes, RowData value) throws IOException {
    byte[] valueBytes = serializeValue(value);
    LookupRecord.OpType opType = convertToOpType(rowKind);
    putIntoQueue(LookupRecord.of(opType, keyBytes, valueBytes));
  }
Writes a key-value pair to the sst file.

@param key The key of the pair.
@param value The value of the pair.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/RocksDBRecordState.java