#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 void	createRenderGroupAnalyzers ()
	Create RenderGroupAnalyzers for poly columns. More...

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 482 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 541 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