#include <InternalCatalogDataWrapper.h>

Inheritance diagram for foreign_storage::InternalCatalogDataWrapper:

Collaboration diagram for foreign_storage::InternalCatalogDataWrapper:

Public Member Functions
	InternalCatalogDataWrapper ()

	InternalCatalogDataWrapper (const int db_id, const ForeignTable *foreign_table)

Public Member Functions inherited from foreign_storage::InternalSystemDataWrapper
	InternalSystemDataWrapper ()

	InternalSystemDataWrapper (const int db_id, const ForeignTable *foreign_table)

void	populateChunkMetadata (ChunkMetadataVector &chunk_metadata_vector) override

void	populateChunkBuffers (const ChunkToBufferMap &required_buffers, const ChunkToBufferMap &optional_buffers, AbstractBuffer *delete_buffer) override

void	validateServerOptions (const ForeignServer *foreign_server) const override

void	validateTableOptions (const ForeignTable *foreign_table) const override

const std::set < std::string_view > &	getSupportedTableOptions () const override

void	validateUserMappingOptions (const UserMapping user_mapping, const ForeignServer foreign_server) const override

const std::set < std::string_view > &	getSupportedUserMappingOptions () const override

std::string	getSerializedDataWrapper () const override

void	restoreDataWrapperInternals (const std::string &file_path, const ChunkMetadataVector &chunk_metadata) override

bool	isRestored () const override

Public Member Functions inherited from foreign_storage::ForeignDataWrapper
	ForeignDataWrapper ()=default

virtual	~ForeignDataWrapper ()=default

virtual const std::set < std::string >	getAlterableTableOptions () const

virtual void	validateSchema (const std::list< ColumnDescriptor > &columns) const

virtual ParallelismLevel	getCachedParallelismLevel () const

virtual ParallelismLevel	getNonCachedParallelismLevel () const

virtual bool	isLazyFragmentFetchingEnabled () const

Private Member Functions
void	initializeObjectsForTable (const std::string &table_name) override

void	populateChunkBuffersForTable (const std::string &table_name, std::map< std::string, import_export::TypedImportBuffer * > &import_buffers) override

Private Attributes
std::list < Catalog_Namespace::UserMetadata >	users_

std::map< int32_t, std::vector < TableDescriptor > >	tables_by_database_

std::map< int32_t, std::vector < DashboardDescriptor > >	dashboards_by_database_

std::vector< ObjectRoleDescriptor >	object_permissions_

std::list < Catalog_Namespace::DBMetadata >	databases_

std::set< std::string >	roles_

std::map< std::string, std::vector< std::string > >	user_names_by_role_

Additional Inherited Members
Public Types inherited from foreign_storage::ForeignDataWrapper
enum	ParallelismLevel { NONE, INTRA_FRAGMENT, INTER_FRAGMENT }

Protected Attributes inherited from foreign_storage::InternalSystemDataWrapper
const int	db_id_

const ForeignTable *	foreign_table_

size_t	row_count_ {0}

Detailed Description

Definition at line 28 of file InternalCatalogDataWrapper.h.

Constructor & Destructor Documentation

foreign_storage::InternalCatalogDataWrapper::InternalCatalogDataWrapper ( )

Definition at line 31 of file InternalCatalogDataWrapper.cpp.

31 : InternalSystemDataWrapper() {}

foreign_storage::InternalSystemDataWrapper::InternalSystemDataWrapper

InternalSystemDataWrapper()

Definition: InternalSystemDataWrapper.cpp:67

foreign_storage::InternalCatalogDataWrapper::InternalCatalogDataWrapper	(	const int	db_id,
		const ForeignTable *	foreign_table
	)

Definition at line 33 of file InternalCatalogDataWrapper.cpp.

35 : InternalSystemDataWrapper(db_id, foreign_table) {}

foreign_storage::InternalSystemDataWrapper::InternalSystemDataWrapper

InternalSystemDataWrapper()

Definition: InternalSystemDataWrapper.cpp:67

Member Function Documentation

void foreign_storage::InternalCatalogDataWrapper::initializeObjectsForTable ( const std::string & table_name )

overrideprivatevirtual

Implements foreign_storage::InternalSystemDataWrapper.

Definition at line 489 of file InternalCatalogDataWrapper.cpp.

                                  {
   row_count_ = 0;
 
   // Dashboads are handled separately since they are only on the aggregator in
   // distributed.  All others are only on the first leaf.
   if (foreign_table_->tableName == Catalog_Namespace::DASHBOARDS_SYS_TABLE_NAME) {
     if (dist::is_distributed() && !dist::is_aggregator()) {
       // Only the aggregator can contain dashboards in distributed.
       return;
     }
     dashboards_by_database_.clear();
     dashboards_by_database_ = get_all_dashboards();
     for (const auto& [db_id, dashboards] : dashboards_by_database_) {
       row_count_ += dashboards.size();
     }
     return;
   }
 
   if (dist::is_distributed() && !dist::is_first_leaf()) {
     // For every table except dashboards, only the first leaf returns information in
     // distributed.
     return;
   }
   auto& sys_catalog = Catalog_Namespace::SysCatalog::instance();
   if (foreign_table_->tableName == Catalog_Namespace::USERS_SYS_TABLE_NAME) {
     users_.clear();
     users_ = sys_catalog.getAllUserMetadata();
     row_count_ = users_.size();
   } else if (foreign_table_->tableName == Catalog_Namespace::TABLES_SYS_TABLE_NAME) {
     tables_by_database_.clear();
     tables_by_database_ = get_all_tables();
     for (const auto& [db_id, tables] : tables_by_database_) {
       row_count_ += tables.size();
     }
   } else if (foreign_table_->tableName == Catalog_Namespace::PERMISSIONS_SYS_TABLE_NAME) {
     object_permissions_.clear();
     object_permissions_ = sys_catalog.getMetadataForAllObjects();
     row_count_ = object_permissions_.size();
   } else if (foreign_table_->tableName == Catalog_Namespace::DATABASES_SYS_TABLE_NAME) {
     databases_.clear();
     databases_ = sys_catalog.getAllDBMetadata();
     row_count_ = databases_.size();
   } else if (foreign_table_->tableName == Catalog_Namespace::ROLES_SYS_TABLE_NAME) {
     roles_.clear();
     roles_ = sys_catalog.getCreatedRoles();
     row_count_ = roles_.size();
   } else if (foreign_table_->tableName ==
              Catalog_Namespace::ROLE_ASSIGNMENTS_SYS_TABLE_NAME) {
     user_names_by_role_.clear();
     user_names_by_role_ = get_all_role_assignments();
     for (const auto& [role, user_names] : user_names_by_role_) {
       row_count_ += user_names.size();
     }
   } else {
     UNREACHABLE() << "Unexpected table name: " << foreign_table_->tableName;
   }
 }

Here is the call graph for this function:

void foreign_storage::InternalCatalogDataWrapper::populateChunkBuffersForTable	(	const std::string &	table_name,
		std::map< std::string, import_export::TypedImportBuffer * > &	import_buffers
	)

overrideprivatevirtual

Implements foreign_storage::InternalSystemDataWrapper.

Definition at line 548 of file InternalCatalogDataWrapper.cpp.

References dashboards_by_database_, Catalog_Namespace::DASHBOARDS_SYS_TABLE_NAME, databases_, Catalog_Namespace::DATABASES_SYS_TABLE_NAME, foreign_storage::InternalSystemDataWrapper::foreign_table_, object_permissions_, Catalog_Namespace::PERMISSIONS_SYS_TABLE_NAME, foreign_storage::anonymous_namespace{InternalCatalogDataWrapper.cpp}::populate_import_buffers_for_catalog_dashboards(), foreign_storage::anonymous_namespace{InternalCatalogDataWrapper.cpp}::populate_import_buffers_for_catalog_databases(), foreign_storage::anonymous_namespace{InternalCatalogDataWrapper.cpp}::populate_import_buffers_for_catalog_permissions(), foreign_storage::anonymous_namespace{InternalCatalogDataWrapper.cpp}::populate_import_buffers_for_catalog_role_assignments(), foreign_storage::anonymous_namespace{InternalCatalogDataWrapper.cpp}::populate_import_buffers_for_catalog_roles(), foreign_storage::anonymous_namespace{InternalCatalogDataWrapper.cpp}::populate_import_buffers_for_catalog_tables(), foreign_storage::anonymous_namespace{InternalCatalogDataWrapper.cpp}::populate_import_buffers_for_catalog_users(), Catalog_Namespace::ROLE_ASSIGNMENTS_SYS_TABLE_NAME, roles_, Catalog_Namespace::ROLES_SYS_TABLE_NAME, TableDescriptor::tableName, tables_by_database_, Catalog_Namespace::TABLES_SYS_TABLE_NAME, UNREACHABLE, user_names_by_role_, users_, and Catalog_Namespace::USERS_SYS_TABLE_NAME.

                                                                         {
   if (foreign_table_->tableName == Catalog_Namespace::USERS_SYS_TABLE_NAME) {
     populate_import_buffers_for_catalog_users(users_, import_buffers);
   } else if (foreign_table_->tableName == Catalog_Namespace::TABLES_SYS_TABLE_NAME) {
     populate_import_buffers_for_catalog_tables(tables_by_database_, import_buffers);
   } else if (foreign_table_->tableName == Catalog_Namespace::DASHBOARDS_SYS_TABLE_NAME) {
     populate_import_buffers_for_catalog_dashboards(dashboards_by_database_,
                                                    import_buffers);
   } else if (foreign_table_->tableName == Catalog_Namespace::PERMISSIONS_SYS_TABLE_NAME) {
     populate_import_buffers_for_catalog_permissions(object_permissions_, import_buffers);
   } else if (foreign_table_->tableName == Catalog_Namespace::DATABASES_SYS_TABLE_NAME) {
     populate_import_buffers_for_catalog_databases(databases_, import_buffers);
   } else if (foreign_table_->tableName == Catalog_Namespace::ROLES_SYS_TABLE_NAME) {
     populate_import_buffers_for_catalog_roles(roles_, import_buffers);
   } else if (foreign_table_->tableName ==
              Catalog_Namespace::ROLE_ASSIGNMENTS_SYS_TABLE_NAME) {
     populate_import_buffers_for_catalog_role_assignments(user_names_by_role_,
                                                          import_buffers);
   } else {
     UNREACHABLE() << "Unexpected table name: " << foreign_table_->tableName;
   }
 }

Here is the call graph for this function:

Member Data Documentation

std::map<int32_t, std::vector<DashboardDescriptor> > foreign_storage::InternalCatalogDataWrapper::dashboards_by_database_

private

Definition at line 43 of file InternalCatalogDataWrapper.h.

Referenced by initializeObjectsForTable(), and populateChunkBuffersForTable().

std::list<Catalog_Namespace::DBMetadata> foreign_storage::InternalCatalogDataWrapper::databases_

private

Definition at line 45 of file InternalCatalogDataWrapper.h.

Referenced by initializeObjectsForTable(), and populateChunkBuffersForTable().

std::vector<ObjectRoleDescriptor> foreign_storage::InternalCatalogDataWrapper::object_permissions_

private

Definition at line 44 of file InternalCatalogDataWrapper.h.

Referenced by initializeObjectsForTable(), and populateChunkBuffersForTable().

std::set<std::string> foreign_storage::InternalCatalogDataWrapper::roles_

private

Definition at line 46 of file InternalCatalogDataWrapper.h.

Referenced by initializeObjectsForTable(), and populateChunkBuffersForTable().

std::map<int32_t, std::vector<TableDescriptor> > foreign_storage::InternalCatalogDataWrapper::tables_by_database_

private

Definition at line 42 of file InternalCatalogDataWrapper.h.

Referenced by initializeObjectsForTable(), and populateChunkBuffersForTable().

std::map<std::string, std::vector<std::string> > foreign_storage::InternalCatalogDataWrapper::user_names_by_role_

private

Definition at line 47 of file InternalCatalogDataWrapper.h.

Referenced by initializeObjectsForTable(), and populateChunkBuffersForTable().

std::list<Catalog_Namespace::UserMetadata> foreign_storage::InternalCatalogDataWrapper::users_

private

Definition at line 41 of file InternalCatalogDataWrapper.h.

Referenced by initializeObjectsForTable(), and populateChunkBuffersForTable().

The documentation for this class was generated from the following files:

/home/jenkins-slave/workspace/core-os-doxygen/DataMgr/ForeignStorage/InternalCatalogDataWrapper.h
/home/jenkins-slave/workspace/core-os-doxygen/DataMgr/ForeignStorage/InternalCatalogDataWrapper.cpp

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation