Method LoadMetaCache

be/src/runtime/io/data-cache.cc:1169–1193

}

Status DataCache::Partition::LoadMetaCache(const DumpData& dump_data) {
  lock_.DCheckLocked();
  for (const DumpData::CacheKeyEntryData& key_entry : dump_data.meta_cache_data) {
    // Usually this shouldn't happen, and if it did, the dump file may be corrupted and
    // loading should be aborted.
    if (UNLIKELY(key_entry.index >= cache_files_.size())) {
      return Status("Failed to load meta cache, the dump file may be corrupted.");
    }

    // According to the index, find the corresponding file pointer, build entry and insert
    // into the cache like normal store. If the cache capacity has been changed, the entry
    // may be evicted, but that's no matter.
    CacheFile* file = cache_files_[key_entry.index].get();
    CacheEntry entry(file, key_entry.offset, key_entry.len, key_entry.checksum);
    const int64_t charge_len = BitUtil::RoundUp(entry.len(), PAGE_SIZE);
    Cache::UniquePendingHandle pending_handle(
        meta_cache_->Allocate(Slice(key_entry.key), sizeof(CacheEntry), charge_len));
    if (UNLIKELY(pending_handle.get() == nullptr)) continue;
    memcpy(meta_cache_->MutableValue(&pending_handle), &entry, sizeof(CacheEntry));
    meta_cache_->Insert(std::move(pending_handle), this);
    ImpaladMetrics::IO_MGR_REMOTE_DATA_CACHE_TOTAL_BYTES->Increment(charge_len);
    ImpaladMetrics::IO_MGR_REMOTE_DATA_CACHE_NUM_ENTRIES->Increment(1);
  }
  return Status::OK();
}

void DataCache::Partition::EvictedEntry(Slice key, Slice value) {
  if (closed_) return;