Catalog_Namespace::anonymous_namespace{Catalog.cpp} Namespace Reference

Functions
auto	table_json_filepath (const std::string &base_path, const std::string &db_name)
std::string	getUserFromId (const int32_t id)
int64_t	get_next_refresh_time (const foreign_storage::ForeignTable &foreign_table)
std::string	table_epochs_to_string (const std::vector< TableEpochInfo > &table_epochs)
const ColumnDescriptor *	get_foreign_col (const Catalog &cat, const Parser::SharedDictionaryDef &shared_dict_def)
void	unserialize_key_metainfo (std::vector< std::string > &shared_dicts, std::set< std::string > &shared_dict_column_names, const std::string keyMetainfo)

Function Documentation

const ColumnDescriptor* Catalog_Namespace::anonymous_namespace{Catalog.cpp}::get_foreign_col	(	const Catalog &	cat,
		const Parser::SharedDictionaryDef &	shared_dict_def
	)

Definition at line 2969 of file Catalog.cpp.

References CHECK, Parser::SharedDictionaryDef::get_foreign_column(), Parser::SharedDictionaryDef::get_foreign_table(), Catalog_Namespace::Catalog::getMetadataForColumn(), Catalog_Namespace::Catalog::getMetadataForTable(), and TableDescriptor::tableId.

Referenced by Catalog_Namespace::Catalog::addReferenceToForeignDict().

                                                      {
  const auto& table_name = shared_dict_def.get_foreign_table();
  const auto td = cat.getMetadataForTable(table_name);
  CHECK(td);
  const auto& foreign_col_name = shared_dict_def.get_foreign_column();
  return cat.getMetadataForColumn(td->tableId, foreign_col_name);
}

Here is the call graph for this function:

Here is the caller graph for this function:

int64_t Catalog_Namespace::anonymous_namespace{Catalog.cpp}::get_next_refresh_time

(

const foreign_storage::ForeignTable &

foreign_table

)

Definition at line 2144 of file Catalog.cpp.

References CHECK, foreign_storage::get_next_refresh_time(), foreign_storage::ForeignTable::NULL_REFRESH_TIME, foreign_storage::OptionsContainer::options, foreign_storage::ForeignTable::REFRESH_TIMING_TYPE_KEY, and foreign_storage::ForeignTable::SCHEDULE_REFRESH_TIMING_TYPE.

Referenced by Catalog_Namespace::Catalog::createTable(), and Catalog_Namespace::Catalog::updateForeignTableRefreshTimes().

                                                                                {
  auto timing_type_entry =
      foreign_table.options.find(foreign_storage::ForeignTable::REFRESH_TIMING_TYPE_KEY);
  CHECK(timing_type_entry != foreign_table.options.end());
  if (timing_type_entry->second ==
      foreign_storage::ForeignTable::SCHEDULE_REFRESH_TIMING_TYPE) {
    return foreign_storage::get_next_refresh_time(foreign_table.options);
  }
  return foreign_storage::ForeignTable::NULL_REFRESH_TIME;
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::string Catalog_Namespace::anonymous_namespace{Catalog.cpp}::getUserFromId

(

const int32_t

id

)

Definition at line 918 of file Catalog.cpp.

References Catalog_Namespace::SysCatalog::instance(), and Catalog_Namespace::UserMetadata::userName.

Referenced by Catalog_Namespace::Catalog::buildMaps().

                                          {
  UserMetadata user;
  if (SysCatalog::instance().getMetadataForUserById(id, user)) {
    return user.userName;
  }
  // a user could be deleted and a dashboard still exist?
  return "Unknown";
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::string Catalog_Namespace::anonymous_namespace{Catalog.cpp}::table_epochs_to_string

(

const std::vector< TableEpochInfo > &

table_epochs

)

Definition at line 2860 of file Catalog.cpp.

References to_string().

Referenced by Catalog_Namespace::Catalog::setTableEpochsLogExceptions().

                                                                                {
  std::string table_epochs_str{"["};
  bool first_entry{true};
  for (const auto& table_epoch : table_epochs) {
    if (first_entry) {
      first_entry = false;
    } else {
      table_epochs_str += ", ";
    }
    table_epochs_str += "(table_id: " + std::to_string(table_epoch.table_id) +
                        ", epoch: " + std::to_string(table_epoch.table_epoch) + ")";
  }
  table_epochs_str += "]";
  return table_epochs_str;
}

Here is the call graph for this function:

Here is the caller graph for this function:

auto Catalog_Namespace::anonymous_namespace{Catalog.cpp}::table_json_filepath ( const std::string &  base_path, const std::string &  db_name  )

inline

Definition at line 153 of file Catalog.cpp.

Referenced by Catalog_Namespace::Catalog::Catalog(), Catalog_Namespace::Catalog::dropTableFromJsonUnlocked(), Catalog_Namespace::Catalog::serializeTableJsonUnlocked(), and Catalog_Namespace::Catalog::~Catalog().

                                                          {
  return boost::filesystem::path(base_path + "/mapd_catalogs/" + db_name +
                                 "_temp_tables.json");
}

Here is the caller graph for this function:

void Catalog_Namespace::anonymous_namespace{Catalog.cpp}::unserialize_key_metainfo	(	std::vector< std::string > &	shared_dicts,
		std::set< std::string > &	shared_dict_column_names,
		const std::string	keyMetainfo
	)

Definition at line 4161 of file Catalog.cpp.

References CHECK, Catalog_Namespace::Catalog::name(), and run_benchmark_import::type.

Referenced by Catalog_Namespace::Catalog::dumpCreateTable().

                                                           {
  rapidjson::Document document;
  document.Parse(keyMetainfo.c_str());
  CHECK(!document.HasParseError());
  CHECK(document.IsArray());
  for (auto it = document.Begin(); it != document.End(); ++it) {
    const auto& key_with_spec_json = *it;
    CHECK(key_with_spec_json.IsObject());
    const std::string type = key_with_spec_json["type"].GetString();
    const std::string name = key_with_spec_json["name"].GetString();
    auto key_with_spec = type + " (" + name + ")";
    if (type == "SHARED DICTIONARY") {
      shared_dict_column_names.insert(name);
      key_with_spec += " REFERENCES ";
      const std::string foreign_table = key_with_spec_json["foreign_table"].GetString();
      const std::string foreign_column = key_with_spec_json["foreign_column"].GetString();
      key_with_spec += foreign_table + "(" + foreign_column + ")";
    } else {
      CHECK(type == "SHARD KEY");
    }
    shared_dicts.push_back(key_with_spec);
  }
}

Here is the call graph for this function:

Here is the caller graph for this function: