Method load_all_array_schemas

tiledb/sm/array/array_directory.cc:153–200

}

std::unordered_map<std::string, shared_ptr<ArraySchema>>
ArrayDirectory::load_all_array_schemas(
    const EncryptionKey& encryption_key,
    shared_ptr<MemoryTracker> memory_tracker) const {
  auto timer_se =
      resources_.get().stats().start_timer("sm_load_all_array_schemas");

  if (uri_.is_invalid()) {
    throw ArrayDirectoryException(
        "Cannot load all array schemas; Invalid array URI");
  }

  const std::vector<URI>& schema_uris = array_schema_uris();
  if (schema_uris.empty()) {
    throw ArrayDirectoryException(
        "Cannot get the array schema vector; No array schemas found.");
  }

  std::vector<shared_ptr<ArraySchema>> schema_vector;
  auto schema_num = schema_uris.size();
  schema_vector.resize(schema_num);

  auto status = parallel_for(
      &resources_.get().compute_tp(), 0, schema_num, [&](size_t schema_ith) {
        auto& schema_uri = schema_uris[schema_ith];
        try {
          auto&& array_schema = load_array_schema_from_uri(
              resources_.get(), schema_uri, encryption_key, memory_tracker);
          array_schema->set_array_uri(uri_);
          schema_vector[schema_ith] = array_schema;
        } catch (std::exception& e) {
          // TODO: We could throw a nested exception, but converting exceptions
          // to statuses loses the inner exception messages. We can revisit this
          // when Status gets removed from this module.
          throw ArrayDirectoryException(e.what());
        }

        return Status::Ok();
      });
  throw_if_not_ok(status);

  std::unordered_map<std::string, shared_ptr<ArraySchema>> array_schemas;
  for (const auto& schema : schema_vector) {
    array_schemas[schema->name()] = schema;
  }

  return array_schemas;
}

std::vector<shared_ptr<const Enumeration>>
ArrayDirectory::load_enumerations_from_paths(