Method Load

be/src/runtime/io/data-cache.cc:1078–1112

}

Status DataCache::Partition::Load() {
  std::ifstream file;
  file.open(JoinPathSegments(path_, DUMP_FILE_NAME), std::ofstream::binary);
  if (!file) return Status::Expected(Substitute("Failed to open $0", DUMP_FILE_NAME));
  LOG(INFO) << Substitute("Partition $0 start loading.", index_);
  DumpData dump_data;
  try {
    dump_data.deserialize(file);
  } catch (boost::archive::archive_exception& e) {
    LOG(ERROR) << Substitute("Partition $0 failed to deserialize dump file.", index_)
               << e.what();
    return Status("Failed to deserialize dump file.");
  }
  file.close();

  Status status = LoadCacheFiles(dump_data);
  if (!status.ok()) {
    cache_files_.clear();
    return status;
  }

  status = LoadMetaCache(dump_data);
  if (!status.ok()) {
    cache_files_.clear();
    meta_cache_.reset(NewCache(GetCacheEvictionPolicy(FLAGS_data_cache_eviction_policy),
        capacity_, path_));
    // We have already successfully initialized meta_cache_ once before calling Load(), so
    // there is no reason for it to fail this time.
    ABORT_IF_ERROR(meta_cache_->Init());
    return status;
  }

  LOG(INFO) << Substitute("Partition $0 load successfully.", index_);
  return Status::OK();
}

Status DataCache::Partition::DumpCacheFiles(DumpData& dump_data) {
  lock_.DCheckLocked();