foreign_storage::ForeignTableSchema Class Reference

#include <ForeignTableSchema.h>

Collaboration diagram for foreign_storage::ForeignTableSchema:

Public Member Functions
	ForeignTableSchema (const int32_t db_id, const ForeignTable *foreign_table)
const ColumnDescriptor *	getColumnDescriptor (const int column_id) const
const ColumnDescriptor *	getLogicalColumn (const int column_id) const
int	getParquetColumnIndex (const int column_id) const
const std::list< const ColumnDescriptor * > &	getLogicalAndPhysicalColumns () const
int	numLogicalAndPhysicalColumns () const
const std::list< const ColumnDescriptor * > &	getLogicalColumns () const
int	numLogicalColumns () const
const ForeignTable *	getForeignTable () const

Private Member Functions
std::vector< int >::const_iterator	getLogicalColumnIdIterator (const int column_id) const

Private Attributes
std::list< const ColumnDescriptor * >	logical_and_physical_columns_
std::list< const ColumnDescriptor * >	logical_columns_
std::vector< int >	logical_column_ids_
const ForeignTable *	foreign_table_
std::shared_ptr < Catalog_Namespace::Catalog >	catalog_

Detailed Description

Definition at line 22 of file ForeignTableSchema.h.

Constructor & Destructor Documentation

foreign_storage::ForeignTableSchema::ForeignTableSchema ( const int32_t  db_id, const ForeignTable *  foreign_table  )

inline

Definition at line 24 of file ForeignTableSchema.h.

References catalog_, CHECK, foreign_table_, Catalog_Namespace::SysCatalog::getCatalog(), Catalog_Namespace::SysCatalog::instance(), logical_and_physical_columns_, logical_column_ids_, logical_columns_, and TableDescriptor::tableId.

                                                                             {
    catalog_ = Catalog_Namespace::SysCatalog::instance().getCatalog(db_id);
    CHECK(catalog_);
    foreign_table_ = foreign_table;
    logical_and_physical_columns_ = catalog_->getAllColumnMetadataForTableUnlocked(
        foreign_table->tableId, false, false, true);
    logical_columns_ = catalog_->getAllColumnMetadataForTableUnlocked(
        foreign_table->tableId, false, false, false);

    for (const auto column : logical_columns_) {
      logical_column_ids_.emplace_back(column->columnId);
    }
  }

Here is the call graph for this function:

Member Function Documentation

const ColumnDescriptor* foreign_storage::ForeignTableSchema::getColumnDescriptor ( const int  column_id ) const

inline

Gets a pointer to the column descriptor object for the given column id.

Definition at line 41 of file ForeignTableSchema.h.

References catalog_, CHECK, foreign_table_, and TableDescriptor::tableId.

Referenced by getLogicalColumn(), foreign_storage::anonymous_namespace{LazyParquetChunkLoader.cpp}::metadata_scan_rowgroup_interval(), and foreign_storage::anonymous_namespace{LazyParquetChunkLoader.cpp}::populate_encoder_map().

                                                                         {
    auto column =
        catalog_->getMetadataForColumnUnlocked(foreign_table_->tableId, column_id);
    CHECK(column);
    return column;
  }

Here is the caller graph for this function:

const ForeignTable* foreign_storage::ForeignTableSchema::getForeignTable ( ) const

inline

Gets a pointer to the foreign table object.

Definition at line 99 of file ForeignTableSchema.h.

References foreign_table_.

Referenced by foreign_storage::anonymous_namespace{LazyParquetChunkLoader.cpp}::validate_column_mapping_and_row_group_metadata().

{ return foreign_table_; }

Here is the caller graph for this function:

const std::list<const ColumnDescriptor*>& foreign_storage::ForeignTableSchema::getLogicalAndPhysicalColumns ( ) const

inline

Gets all the logical and physical columns for the foreign table.

Definition at line 73 of file ForeignTableSchema.h.

References logical_and_physical_columns_.

Referenced by foreign_storage::anonymous_namespace{LazyParquetChunkLoader.cpp}::metadata_scan_rowgroup_interval(), and foreign_storage::LazyParquetChunkLoader::metadataScan().

                                                                               {
    return logical_and_physical_columns_;
  }

Here is the caller graph for this function:

const ColumnDescriptor* foreign_storage::ForeignTableSchema::getLogicalColumn ( const int  column_id ) const

inline

Gets the logical column that is associated with the given column id. Given column id can be for a physical column or logical column (in this case, the column descriptor for the same column is returned)

Definition at line 53 of file ForeignTableSchema.h.

References CHECK_LE, getColumnDescriptor(), and getLogicalColumnIdIterator().

Referenced by foreign_storage::anonymous_namespace{LazyParquetChunkLoader.cpp}::metadata_scan_rowgroup_interval().

                                                                      {
    auto logical_column_id = *getLogicalColumnIdIterator(column_id);
    CHECK_LE(logical_column_id, column_id);
    return getColumnDescriptor(logical_column_id);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

std::vector<int>::const_iterator foreign_storage::ForeignTableSchema::getLogicalColumnIdIterator ( const int  column_id ) const

inlineprivate

Definition at line 102 of file ForeignTableSchema.h.

References CHECK, logical_column_ids_, and gpu_enabled::upper_bound().

Referenced by getLogicalColumn(), and getParquetColumnIndex().

                                                                                     {
    auto it = std::upper_bound(
        logical_column_ids_.begin(), logical_column_ids_.end(), column_id);
    CHECK(it != logical_column_ids_.begin());
    it--;
    return it;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

const std::list<const ColumnDescriptor*>& foreign_storage::ForeignTableSchema::getLogicalColumns ( ) const

inline

Gets all the logical columns for the foreign table.

Definition at line 87 of file ForeignTableSchema.h.

References logical_columns_.

Referenced by foreign_storage::anonymous_namespace{LazyParquetChunkLoader.cpp}::validate_column_mapping_and_row_group_metadata().

                                                                    {
    return logical_columns_;
  }

Here is the caller graph for this function:

int foreign_storage::ForeignTableSchema::getParquetColumnIndex ( const int  column_id ) const

inline

Gets the Parquet column index that corresponds to the given column id.

Definition at line 63 of file ForeignTableSchema.h.

References CHECK_GE, getLogicalColumnIdIterator(), and logical_column_ids_.

Referenced by foreign_storage::anonymous_namespace{LazyParquetChunkLoader.cpp}::metadata_scan_rowgroup_interval(), and foreign_storage::anonymous_namespace{LazyParquetChunkLoader.cpp}::populate_encoder_map().

                                                       {
    auto column_index =
        std::distance(logical_column_ids_.begin(), getLogicalColumnIdIterator(column_id));
    CHECK_GE(column_index, 0);
    return column_index;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

int foreign_storage::ForeignTableSchema::numLogicalAndPhysicalColumns ( ) const

inline

Gets the total number of logical and physical columns for the foreign table.

Definition at line 80 of file ForeignTableSchema.h.

References logical_and_physical_columns_.

                                           {
    return logical_and_physical_columns_.size();
  }

int foreign_storage::ForeignTableSchema::numLogicalColumns ( ) const

inline

Gets the total number of logical columns for the foreign table.

Definition at line 94 of file ForeignTableSchema.h.

References logical_columns_.

Referenced by foreign_storage::anonymous_namespace{LazyParquetChunkLoader.cpp}::validate_number_of_columns().

{ return logical_columns_.size(); }

Here is the caller graph for this function:

Member Data Documentation

std::shared_ptr<Catalog_Namespace::Catalog> foreign_storage::ForeignTableSchema::catalog_

private

Definition at line 114 of file ForeignTableSchema.h.

Referenced by ForeignTableSchema(), and getColumnDescriptor().

const ForeignTable* foreign_storage::ForeignTableSchema::foreign_table_

private

Definition at line 113 of file ForeignTableSchema.h.

Referenced by ForeignTableSchema(), getColumnDescriptor(), and getForeignTable().

std::list<const ColumnDescriptor*> foreign_storage::ForeignTableSchema::logical_and_physical_columns_

private

Definition at line 110 of file ForeignTableSchema.h.

Referenced by ForeignTableSchema(), getLogicalAndPhysicalColumns(), and numLogicalAndPhysicalColumns().

std::vector<int> foreign_storage::ForeignTableSchema::logical_column_ids_

private

Definition at line 112 of file ForeignTableSchema.h.

Referenced by ForeignTableSchema(), getLogicalColumnIdIterator(), and getParquetColumnIndex().

std::list<const ColumnDescriptor*> foreign_storage::ForeignTableSchema::logical_columns_

private

Definition at line 111 of file ForeignTableSchema.h.

Referenced by ForeignTableSchema(), getLogicalColumns(), and numLogicalColumns().

---

The documentation for this class was generated from the following file:

• /home/jenkins-slave/workspace/core-os-doxygen/DataMgr/ForeignStorage/ForeignTableSchema.h