Method evolve_schema

tiledb/sm/array_schema/array_schema_evolution.cc:127–186

/* ****************************** */

shared_ptr<ArraySchema> ArraySchemaEvolution::evolve_schema(
    const shared_ptr<const ArraySchema>& orig_schema) {
  std::lock_guard<std::mutex> lock(mtx_);
  if (orig_schema == nullptr) {
    throw ArraySchemaEvolutionException(
        "Cannot evolve schema; Input array schema is null");
  }

  auto schema = orig_schema->clone();

  // Add enumerations. Must be done before attributes so that any attributes
  // referencing enumerations won't fail to be added.
  for (auto& enmr : enumerations_to_add_map_) {
    schema->add_enumeration(enmr.second);
  }

  for (auto& enmr : enumerations_to_extend_map_) {
    schema->extend_enumeration(enmr.second);
  }

  // Add attributes.
  for (auto& attr : attributes_to_add_) {
    schema->add_attribute(attr, false);
  }

  // Drop attributes.
  for (auto& attr_name : attributes_to_drop_) {
    const bool has_attr = schema->has_attribute(attr_name);
    if (!has_attr) {
      throw ArraySchemaEvolutionException(
          "Cannot drop attribute; Input attribute name refers to a dimension "
          "or does not exist");
    }
    schema->drop_attribute(attr_name);
  }

  // Drop enumerations
  for (auto& enmr_name : enumerations_to_drop_) {
    if (schema->has_enumeration(enmr_name)) {
      schema->drop_enumeration(enmr_name);
    }
  }

  // Set timestamp, if specified
  if (std::get<0>(timestamp_range_) != 0) {
    schema->generate_uri(timestamp_range_);
  } else {
    // Generate new schema URI
    schema->generate_uri();
  }

  // Get expanded current domain
  if (current_domain_to_expand_) {
    schema->expand_current_domain(current_domain_to_expand_);
  }

  schema->check_without_config();