foreign_storage::InternalExecutorStatsDataWrapper Class Reference

#include <InternalExecutorStatsDataWrapper.h>

Inheritance diagram for foreign_storage::InternalExecutorStatsDataWrapper:

Collaboration diagram for foreign_storage::InternalExecutorStatsDataWrapper:

Public Member Functions
	InternalExecutorStatsDataWrapper ()
	InternalExecutorStatsDataWrapper (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
ExecutorResourceMgr_Namespace::ResourcePoolInfo	executor_resource_pool_info_

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 31 of file InternalExecutorStatsDataWrapper.h.

Constructor & Destructor Documentation

foreign_storage::InternalExecutorStatsDataWrapper::InternalExecutorStatsDataWrapper

(

)

Definition at line 24 of file InternalExecutorStatsDataWrapper.cpp.

    : InternalSystemDataWrapper() {}

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

Definition at line 27 of file InternalExecutorStatsDataWrapper.cpp.

    : InternalSystemDataWrapper(db_id, foreign_table) {}

Member Function Documentation

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

overrideprivatevirtual

Implements foreign_storage::InternalSystemDataWrapper.

Definition at line 123 of file InternalExecutorStatsDataWrapper.cpp.

References CHECK_EQ, executor_resource_pool_info_, Catalog_Namespace::EXECUTOR_RESOURCE_POOL_SUMMARY_SYS_TABLE_NAME, foreign_storage::InternalSystemDataWrapper::foreign_table_, Executor::get_executor_resource_pool_info(), foreign_storage::InternalSystemDataWrapper::row_count_, and TableDescriptor::tableName.

                                 {
  CHECK_EQ(foreign_table_->tableName, table_name);
  CHECK_EQ(foreign_table_->tableName,
           Catalog_Namespace::EXECUTOR_RESOURCE_POOL_SUMMARY_SYS_TABLE_NAME)
      << "Unexpected table name: " << foreign_table_->tableName;
  executor_resource_pool_info_ = Executor::get_executor_resource_pool_info();
  row_count_ = 1;
}

Here is the call graph for this function:

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

overrideprivatevirtual

Implements foreign_storage::InternalSystemDataWrapper.

Definition at line 133 of file InternalExecutorStatsDataWrapper.cpp.

References CHECK_EQ, executor_resource_pool_info_, Catalog_Namespace::EXECUTOR_RESOURCE_POOL_SUMMARY_SYS_TABLE_NAME, foreign_storage::InternalSystemDataWrapper::foreign_table_, foreign_storage::anonymous_namespace{InternalExecutorStatsDataWrapper.cpp}::populate_import_buffers_for_executor_resource_pool_summary(), and TableDescriptor::tableName.

                                                                        {
  CHECK_EQ(foreign_table_->tableName, table_name);
  CHECK_EQ(foreign_table_->tableName,
           Catalog_Namespace::EXECUTOR_RESOURCE_POOL_SUMMARY_SYS_TABLE_NAME)
      << "Unexpected table name: " << foreign_table_->tableName;
  populate_import_buffers_for_executor_resource_pool_summary(executor_resource_pool_info_,
                                                             import_buffers);
}

Here is the call graph for this function:

Member Data Documentation

ExecutorResourceMgr_Namespace::ResourcePoolInfo foreign_storage::InternalExecutorStatsDataWrapper::executor_resource_pool_info_

private

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