public void put(byte[] keyBytes, RowData value) throws IOException {
    Preconditions.checkNotNull(value);

    byte[] valueBytes = serializeValue(value);
    rocksDB.put(columnFamilyHandle, keyBytes, valueBytes);

    // Speed up the initialization process of Lookup Join Function
    ByteArrayWrapper key = wrap(keyBytes);
    if (guavaCache.getIfPresent(wrap(keyBytes)) != null) {
      guavaCache.put(key, valueBytes);
    }
  }
Putting the serialized RowData key and value into the rocksDB and cache.

@throws IOException if serialize the RowData variable key and value failed.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/RocksDBRecordState.java