#include <InternalStorageStatsDataWrapper.h>

Inheritance diagram for foreign_storage::InternalStorageStatsDataWrapper:

Collaboration diagram for foreign_storage::InternalStorageStatsDataWrapper:

Public Member Functions
	InternalStorageStatsDataWrapper ()

	InternalStorageStatsDataWrapper (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::vector< StorageDetails >	storage_details_

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 45 of file InternalStorageStatsDataWrapper.h.

Constructor & Destructor Documentation

foreign_storage::InternalStorageStatsDataWrapper::InternalStorageStatsDataWrapper ( )

Definition at line 25 of file InternalStorageStatsDataWrapper.cpp.

26 : InternalSystemDataWrapper() {}

foreign_storage::InternalSystemDataWrapper::InternalSystemDataWrapper

InternalSystemDataWrapper()

Definition: InternalSystemDataWrapper.cpp:67

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

Definition at line 28 of file InternalStorageStatsDataWrapper.cpp.

31 : InternalSystemDataWrapper(db_id, foreign_table) {}

foreign_storage::InternalSystemDataWrapper::InternalSystemDataWrapper

InternalSystemDataWrapper()

Definition: InternalSystemDataWrapper.cpp:67

Member Function Documentation

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

overrideprivatevirtual

Implements foreign_storage::InternalSystemDataWrapper.

Definition at line 124 of file InternalStorageStatsDataWrapper.cpp.

References CHECK, CHECK_EQ, Catalog_Namespace::SysCatalog::getDataMgr(), Data_Namespace::DataMgr::getGlobalFileMgr(), Catalog_Namespace::SysCatalog::instance(), shared::kInfoSchemaDbName, foreign_storage::InternalSystemDataWrapper::row_count_, storage_details_, and Catalog_Namespace::STORAGE_DETAILS_SYS_TABLE_NAME.

                                  {
   CHECK_EQ(table_name, Catalog_Namespace::STORAGE_DETAILS_SYS_TABLE_NAME);
   storage_details_.clear();
   const auto global_file_mgr =
       Catalog_Namespace::SysCatalog::instance().getDataMgr().getGlobalFileMgr();
   CHECK(global_file_mgr);
   auto& sys_catalog = Catalog_Namespace::SysCatalog::instance();
   for (const auto& catalog : sys_catalog.getCatalogsForAllDbs()) {
     if (catalog->name() != shared::kInfoSchemaDbName) {
       std::set<std::string> found_dict_paths;
       for (const auto& [table_id, shard_id] :
            catalog->getAllPersistedTableAndShardIds()) {
         uint64_t total_dictionary_file_size{0};
         auto logical_table_id = catalog->getLogicalTableId(table_id);
         for (const auto& dict_path :
              catalog->getTableDictDirectoryPaths(logical_table_id)) {
           if (found_dict_paths.find(dict_path) == found_dict_paths.end()) {
             found_dict_paths.emplace(dict_path);
           } else {
             // Skip shared dictionaries.
             continue;
           }
           CHECK(std::filesystem::is_directory(dict_path));
           for (const auto& file_entry : std::filesystem::directory_iterator(dict_path)) {
             CHECK(file_entry.is_regular_file());
             total_dictionary_file_size += static_cast<uint64_t>(file_entry.file_size());
           }
         }
         auto db_id = catalog->getDatabaseId();
         storage_details_.emplace_back(db_id,
                                       logical_table_id,
                                       shard_id,
                                       total_dictionary_file_size,
                                       global_file_mgr->getStorageStats(db_id, table_id));
       }
     }
   }
   row_count_ = storage_details_.size();
 }

Here is the call graph for this function:

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

overrideprivatevirtual

Implements foreign_storage::InternalSystemDataWrapper.

Definition at line 165 of file InternalStorageStatsDataWrapper.cpp.

References CHECK_EQ, foreign_storage::anonymous_namespace{InternalStorageStatsDataWrapper.cpp}::populate_import_buffers_for_storage_details(), storage_details_, and Catalog_Namespace::STORAGE_DETAILS_SYS_TABLE_NAME.

                                                                         {
   CHECK_EQ(table_name, Catalog_Namespace::STORAGE_DETAILS_SYS_TABLE_NAME);
   populate_import_buffers_for_storage_details(storage_details_, import_buffers);
 }

Here is the call graph for this function:

Member Data Documentation

std::vector<StorageDetails> foreign_storage::InternalStorageStatsDataWrapper::storage_details_

private

Definition at line 58 of file InternalStorageStatsDataWrapper.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/InternalStorageStatsDataWrapper.h
/home/jenkins-slave/workspace/core-os-doxygen/DataMgr/ForeignStorage/InternalStorageStatsDataWrapper.cpp

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation