OmniSciDB
bf83d84833
|
#include <TableDescriptor.h>
Public Member Functions | |
TableDescriptor () | |
virtual | ~TableDescriptor ()=default |
bool | isForeignTable () const |
bool | isTemporaryTable () const |
Public Attributes | |
int32_t | tableId |
int32_t | shard |
std::string | tableName |
int32_t | userId |
int32_t | nColumns |
bool | isView |
std::string | viewSQL |
std::string | fragments |
Fragmenter_Namespace::FragmenterType | fragType |
int32_t | maxFragRows |
int64_t | maxChunkSize |
int32_t | fragPageSize |
int64_t | maxRows |
std::string | partitions |
std::string | keyMetainfo |
std::shared_ptr < Fragmenter_Namespace::AbstractFragmenter > | fragmenter |
int32_t | nShards |
int | shardedColumnId |
int | sortedColumnId |
Data_Namespace::MemoryLevel | persistenceLevel |
bool | hasDeletedCol |
std::vector< int > | columnIdBySpi_ |
std::string | storageType |
int32_t | maxRollbackEpochs |
std::shared_ptr< std::mutex > | mutex_ |
Definition at line 43 of file TableDescriptor.h.
|
inline |
Definition at line 82 of file TableDescriptor.h.
|
virtualdefault |
|
inline |
Definition at line 95 of file TableDescriptor.h.
References StorageType::FOREIGN_TABLE, and storageType.
Referenced by system_validator::should_validate_epoch().
|
inline |
Definition at line 97 of file TableDescriptor.h.
References Data_Namespace::CPU_LEVEL, and persistenceLevel.
Referenced by system_validator::should_validate_epoch().
std::vector<int> TableDescriptor::columnIdBySpi_ |
Definition at line 74 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::addTableToMap(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), and Catalog_Namespace::Catalog::roll().
std::shared_ptr<Fragmenter_Namespace::AbstractFragmenter> TableDescriptor::fragmenter |
Definition at line 63 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::checkMetadataForDeletedRecs(), DataframeTableDescriptor::DataframeTableDescriptor(), Catalog_Namespace::Catalog::doTruncateTable(), Catalog_Namespace::Catalog::eraseTablePhysicalData(), Parser::CreateDataframeStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), getChunkAccessorTable(), Catalog_Namespace::Catalog::getMetadataForTableImpl(), Catalog_Namespace::Catalog::instantiateFragmenter(), foreign_storage::ParquetDataWrapper::loadBuffersUsingLazyParquetChunkLoader(), import_export::Loader::loadToShard(), Catalog_Namespace::Catalog::removeChunks(), Catalog_Namespace::Catalog::removeFragmenterForTable(), Catalog_Namespace::Catalog::removeTableFromMap(), ddl_utils::set_default_table_attributes(), foreign_storage::CsvDataWrapper::updateMetadata(), and Catalog_Namespace::Catalog::vacuumDeletedRows().
std::string TableDescriptor::fragments |
Definition at line 51 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::buildMaps(), DataframeTableDescriptor::DataframeTableDescriptor(), and CreateForeignTableCommand::setTableDetails().
int32_t TableDescriptor::fragPageSize |
Definition at line 56 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Catalog_Namespace::Catalog::dumpCreateTable(), Catalog_Namespace::Catalog::dumpSchema(), Parser::CreateDataframeStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), Catalog_Namespace::Catalog::instantiateFragmenter(), and ddl_utils::set_default_table_attributes().
Fragmenter_Namespace::FragmenterType TableDescriptor::fragType |
Definition at line 53 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Parser::CreateDataframeStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), Catalog_Namespace::Catalog::instantiateFragmenter(), and ddl_utils::set_default_table_attributes().
bool TableDescriptor::hasDeletedCol |
Definition at line 70 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::addTableToMap(), Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Catalog_Namespace::Catalog::dumpCreateTable(), Catalog_Namespace::Catalog::dumpSchema(), ArrowForeignStorage::prepareTable(), ArrowCsvForeignStorage::prepareTable(), Catalog_Namespace::Catalog::removeTableFromMap(), TableArchiver::restoreTable(), and CreateForeignTableCommand::setTableDetails().
bool TableDescriptor::isView |
Definition at line 49 of file TableDescriptor.h.
Referenced by Parser::InsertStmt::analyze(), Catalog_Namespace::Catalog::buildMaps(), Parser::AddColumnStmt::check_executable(), checkPermissionForTables(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Parser::InsertValuesStmt::determineLeafIndex(), Catalog_Namespace::Catalog::dropTable(), Catalog_Namespace::Catalog::dumpCreateTable(), TableArchiver::dumpTable(), Catalog_Namespace::Catalog::eraseTablePhysicalData(), Parser::CreateDataframeStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), Catalog_Namespace::Catalog::executeDropTableSqliteQueries(), Catalog_Namespace::Catalog::filterTableByTypeAndUser(), Catalog_Namespace::Catalog::getMetadataForTableImpl(), DBHandler::hasTableAccessPrivileges(), TableArchiver::restoreTable(), ddl_utils::set_default_table_attributes(), system_validator::should_validate_epoch(), and ddl_utils::validate_table_type().
std::string TableDescriptor::keyMetainfo |
Definition at line 60 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Catalog_Namespace::Catalog::dumpCreateTable(), Parser::CreateDataframeStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), Parser::CreateTableStmt::executeDryRun(), and CreateForeignTableCommand::setTableDetails().
int64_t TableDescriptor::maxChunkSize |
Definition at line 55 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Catalog_Namespace::Catalog::dumpCreateTable(), Catalog_Namespace::Catalog::dumpSchema(), Parser::CreateDataframeStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), Catalog_Namespace::Catalog::instantiateFragmenter(), and ddl_utils::set_default_table_attributes().
int32_t TableDescriptor::maxFragRows |
Definition at line 54 of file TableDescriptor.h.
Referenced by foreign_storage::anonymous_namespace{CsvDataWrapper.cpp}::add_placeholder_metadata(), anonymous_namespace{DdlCommandExecutor.cpp}::add_table_details(), Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Catalog_Namespace::Catalog::dumpCreateTable(), Catalog_Namespace::Catalog::dumpSchema(), Parser::CreateDataframeStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), Catalog_Namespace::Catalog::instantiateFragmenter(), foreign_storage::ParquetDataWrapper::moveToNextFragment(), ArrowForeignStorageBase::parseArrowTable(), foreign_storage::CsvDataWrapper::populateChunkMetadata(), ddl_utils::set_default_table_attributes(), and foreign_storage::anonymous_namespace{LazyParquetChunkLoader.cpp}::validate_column_mapping_and_row_group_metadata().
int32_t TableDescriptor::maxRollbackEpochs |
Definition at line 77 of file TableDescriptor.h.
Referenced by anonymous_namespace{DdlCommandExecutor.cpp}::add_table_details(), Catalog_Namespace::Catalog::alterPhysicalTableMetadata(), Catalog_Namespace::Catalog::buildMaps(), Fragmenter_Namespace::InsertOrderFragmenter::conditionallyInstantiateFileMgrWithParams(), Catalog_Namespace::Catalog::createTable(), Catalog_Namespace::Catalog::dumpCreateTable(), Catalog_Namespace::Catalog::dumpSchema(), Parser::CreateTableAsSelectStmt::execute(), TableDescriptorUpdateParams::operator==(), Catalog_Namespace::Catalog::setTableEpoch(), and Catalog_Namespace::Catalog::setTableEpochs().
int64_t TableDescriptor::maxRows |
Definition at line 57 of file TableDescriptor.h.
Referenced by anonymous_namespace{DdlCommandExecutor.cpp}::add_table_details(), Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Catalog_Namespace::Catalog::dumpCreateTable(), Catalog_Namespace::Catalog::dumpSchema(), Parser::CreateDataframeStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), Catalog_Namespace::Catalog::instantiateFragmenter(), and ddl_utils::set_default_table_attributes().
std::shared_ptr<std::mutex> TableDescriptor::mutex_ |
Definition at line 80 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::addTableToMap(), DataframeTableDescriptor::DataframeTableDescriptor(), and Catalog_Namespace::Catalog::getMetadataForTableImpl().
int32_t TableDescriptor::nColumns |
Definition at line 48 of file TableDescriptor.h.
Referenced by anonymous_namespace{DdlCommandExecutor.cpp}::add_table_details(), Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Parser::CreateDataframeStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), Fragmenter_Namespace::get_chunks(), Fragmenter_Namespace::InsertOrderFragmenter::getChunksForAllColumns(), and ddl_utils::set_default_table_attributes().
int32_t TableDescriptor::nShards |
Definition at line 66 of file TableDescriptor.h.
Referenced by anonymous_namespace{DdlCommandExecutor.cpp}::add_table_details(), Catalog_Namespace::Catalog::addColumn(), RelModify::applyUpdateModificationsToInputNode(), Catalog_Namespace::Catalog::buildMaps(), anonymous_namespace{DBHandler.cpp}::check_table_not_sharded(), Catalog_Namespace::Catalog::createShardedTable(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Parser::InsertValuesStmt::determineLeafIndex(), import_export::Loader::distributeToShards(), Catalog_Namespace::Catalog::dropColumn(), import_export::Loader::dropColumns(), Catalog_Namespace::Catalog::dumpCreateTable(), Catalog_Namespace::Catalog::dumpSchema(), Parser::CreateTableStmt::executeDryRun(), anonymous_namespace{DdlCommandExecutor.cpp}::get_agg_storage_stats(), import_export::Loader::loadImpl(), TableOptimizer::recomputeMetadata(), TableArchiver::restoreTable(), and GroupByAndAggregate::shard_count_for_top_groups().
std::string TableDescriptor::partitions |
Definition at line 58 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Parser::InsertValuesStmt::determineLeafIndex(), Catalog_Namespace::Catalog::dumpCreateTable(), Catalog_Namespace::Catalog::dumpSchema(), CreateForeignTableCommand::setTableDetails(), and table_is_replicated().
Data_Namespace::MemoryLevel TableDescriptor::persistenceLevel |
Definition at line 69 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Catalog_Namespace::Catalog::dumpCreateTable(), TableArchiver::dumpTable(), Parser::CreateDataframeStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), Parser::CreateTableStmt::executeDryRun(), Catalog_Namespace::Catalog::instantiateFragmenter(), isTemporaryTable(), Catalog_Namespace::Catalog::removeTableFromMap(), TableArchiver::restoreTable(), Catalog_Namespace::Catalog::setTableEpoch(), Catalog_Namespace::Catalog::setTableFileMgrParams(), and table_is_temporary().
int32_t TableDescriptor::shard |
Definition at line 45 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::addColumn(), Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::createShardedTable(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Catalog_Namespace::Catalog::dropColumn(), Catalog_Namespace::Catalog::filterTableByTypeAndUser(), Catalog_Namespace::Catalog::getDictionaryToColumnMapping(), Catalog_Namespace::Catalog::instantiateFragmenter(), and system_validator::should_validate_epoch().
int TableDescriptor::shardedColumnId |
Definition at line 67 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), import_export::Loader::distributeToShards(), Catalog_Namespace::Catalog::dumpCreateTable(), Catalog_Namespace::Catalog::dumpSchema(), Parser::CreateTableStmt::executeDryRun(), and Catalog_Namespace::Catalog::getShardColumnMetadataForTable().
int TableDescriptor::sortedColumnId |
Definition at line 68 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Catalog_Namespace::Catalog::dumpCreateTable(), Catalog_Namespace::Catalog::dumpSchema(), and Catalog_Namespace::Catalog::instantiateFragmenter().
std::string TableDescriptor::storageType |
Definition at line 75 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Parser::CreateDataframeStmt::execute(), Catalog_Namespace::Catalog::executeDropTableSqliteQueries(), Catalog_Namespace::Catalog::instantiateFragmenter(), isForeignTable(), ForeignStorageInterface::prepareTable(), ForeignStorageInterface::registerTable(), CreateForeignTableCommand::setTableDetails(), foreign_storage::validate_non_foreign_table_write(), and ddl_utils::validate_table_type().
int32_t TableDescriptor::tableId |
tableId starts at 0 for valid tables.
Definition at line 44 of file TableDescriptor.h.
Referenced by lockmgr::TableDataLockContainer< WriteLock >::acquire(), lockmgr::TableDataLockContainer< ReadLock >::acquire(), lockmgr::TableInsertLockContainer< WriteLock >::acquire(), lockmgr::TableInsertLockContainer< ReadLock >::acquire(), Analyzer::RangeTableEntry::add_all_column_descs(), foreign_storage::anonymous_namespace{CsvDataWrapper.cpp}::add_placeholder_metadata(), anonymous_namespace{DdlCommandExecutor.cpp}::add_table_details(), Catalog_Namespace::Catalog::addColumn(), Catalog_Namespace::Catalog::addTableToMap(), Catalog_Namespace::Catalog::alterPhysicalTableMetadata(), Catalog_Namespace::Catalog::alterTableMetadata(), Parser::InsertStmt::analyze(), RelModify::applyUpdateModificationsToInputNode(), Catalog_Namespace::Catalog::buildMaps(), Parser::AddColumnStmt::check_executable(), Catalog_Namespace::Catalog::checkMetadataForDeletedRecs(), checkPermissionForTables(), compare_td_id(), Catalog_Namespace::Catalog::createShardedTable(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Parser::InsertValuesStmt::determineLeafIndex(), Catalog_Namespace::Catalog::doTruncateTable(), Catalog_Namespace::Catalog::dropColumn(), Catalog_Namespace::Catalog::dropTable(), Catalog_Namespace::Catalog::dumpCreateTable(), Catalog_Namespace::Catalog::dumpSchema(), TableArchiver::dumpTable(), Catalog_Namespace::Catalog::eraseTablePhysicalData(), Catalog_Namespace::Catalog::executeDropTableSqliteQueries(), Analyzer::RangeTableEntry::expand_star_in_targetlist(), foreign_storage::ForeignTable::ForeignTable(), foreign_storage::ForeignTableSchema::ForeignTableSchema(), anonymous_namespace{DdlCommandExecutor.cpp}::get_agg_storage_stats(), Fragmenter_Namespace::get_chunks(), Analyzer::RangeTableEntry::get_column_desc(), Catalog_Namespace::anonymous_namespace{Catalog.cpp}::get_foreign_col(), Analyzer::RangeTableEntry::get_table_id(), Catalog_Namespace::Catalog::getAllColumnMetadataForTableImpl(), getChunkAccessorTable(), Fragmenter_Namespace::InsertOrderFragmenter::getChunksForAllColumns(), foreign_storage::ForeignTableSchema::getColumnDescriptor(), Catalog_Namespace::Catalog::getDeletedColumnIfRowsDeleted(), Catalog_Namespace::Catalog::getDictionaryToColumnMapping(), Catalog_Namespace::Catalog::getPhysicalTablesDescriptors(), Catalog_Namespace::Catalog::getShardColumnMetadataForTable(), Catalog_Namespace::Catalog::getTableDictDirectories(), DBHandler::import_geo_table(), import_export::Loader::init(), foreign_storage::ParquetDataWrapper::initializeChunkBuffers(), Parser::LocalConnector::insertDataToLeaf(), Catalog_Namespace::Catalog::instantiateFragmenter(), foreign_storage::ParquetDataWrapper::loadBuffersUsingLazyParquetChunkLoader(), foreign_storage::ParquetDataWrapper::metadataScanFiles(), foreign_storage::CsvDataWrapper::populateChunkBuffers(), foreign_storage::CsvDataWrapper::populateChunkMapForColumns(), foreign_storage::CsvDataWrapper::populateChunkMetadata(), TableOptimizer::recomputeMetadata(), ForeignStorageInterface::registerTable(), AlterForeignTableCommand::renameColumn(), Catalog_Namespace::Catalog::renameColumn(), Catalog_Namespace::Catalog::renamePhysicalTable(), Catalog_Namespace::Catalog::renameTable(), TableArchiver::restoreTable(), Catalog_Namespace::Catalog::serializeTableJsonUnlocked(), Catalog_Namespace::Catalog::setForeignTableProperty(), Catalog_Namespace::Catalog::truncateTable(), Fragmenter_Namespace::InsertOrderFragmenter::updateColumn(), Fragmenter_Namespace::InsertOrderFragmenter::updateColumns(), foreign_storage::CsvDataWrapper::updateMetadata(), TableOptimizer::vacuumDeletedRows(), Catalog_Namespace::Catalog::vacuumDeletedRows(), and anonymous_namespace{QueryPhysicalInputsCollector.cpp}::RelAlgPhysicalTableInputsVisitor::visitScan().
std::string TableDescriptor::tableName |
tableName is the name of the table table -must be unique
Definition at line 46 of file TableDescriptor.h.
Referenced by lockmgr::TableDataLockContainer< WriteLock >::acquire(), lockmgr::TableDataLockContainer< ReadLock >::acquire(), lockmgr::TableInsertLockContainer< WriteLock >::acquire(), lockmgr::TableInsertLockContainer< ReadLock >::acquire(), anonymous_namespace{DdlCommandExecutor.cpp}::add_table_details(), Catalog_Namespace::Catalog::addTableToMap(), Catalog_Namespace::Catalog::alterTableMetadata(), Catalog_Namespace::Catalog::buildMaps(), Parser::check_alter_table_privilege(), Catalog_Namespace::Catalog::createShardedTable(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Catalog_Namespace::Catalog::doDropTable(), Catalog_Namespace::Catalog::dropTable(), Catalog_Namespace::Catalog::dumpCreateTable(), TableArchiver::dumpTable(), Catalog_Namespace::Catalog::eraseTablePhysicalData(), Parser::CreateTableStmt::execute(), Parser::CreateDataframeStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), Parser::CreateViewStmt::execute(), Catalog_Namespace::Catalog::filterTableByTypeAndUser(), Analyzer::RangeTableEntry::get_table_name(), getChunkAccessorTable(), Catalog_Namespace::Catalog::getTableNamesForUser(), Catalog_Namespace::Catalog::getTablesMetadataForUser(), DBHandler::hasTableAccessPrivileges(), Catalog_Namespace::Catalog::instantiateFragmenter(), TableOptimizer::recomputeMetadata(), Catalog_Namespace::Catalog::renameColumn(), Catalog_Namespace::Catalog::renamePhysicalTable(), TableArchiver::restoreTable(), Catalog_Namespace::Catalog::roll(), Catalog_Namespace::Catalog::serializeTableJsonUnlocked(), ddl_utils::set_default_table_attributes(), Catalog_Namespace::Catalog::setColumnDictionary(), Catalog_Namespace::Catalog::setColumnSharedDictionary(), Catalog_Namespace::Catalog::setForeignTableProperty(), RelScan::toString(), RelModify::toString(), DBHandler::user_can_access_table(), and ddl_utils::validate_table_type().
int32_t TableDescriptor::userId |
Definition at line 47 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::buildMaps(), Parser::check_alter_table_privilege(), checkPermissionForTables(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), Parser::CreateTableStmt::execute(), Parser::CreateDataframeStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), and CreateForeignTableCommand::setTableDetails().
std::string TableDescriptor::viewSQL |
Definition at line 50 of file TableDescriptor.h.
Referenced by Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::createTable(), DataframeTableDescriptor::DataframeTableDescriptor(), and Catalog_Namespace::Catalog::dumpCreateTable().