#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 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::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 123 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 164 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