Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext Class Reference

Inheritance diagram for Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext:

Collaboration diagram for Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext:

Public Member Functions
	BaseAlterColumnContext (int device_id, const ChunkKey &chunk_key_prefix, Fragmenter_Namespace::FragmentInfo *fragment_info, const ColumnDescriptor *src_cd, const ColumnDescriptor *dst_cd, const size_t num_elements, Data_Namespace::DataMgr *data_mgr, Catalog_Namespace::Catalog *catalog, std::map< int, Chunk_NS::Chunk > &column_map)
void	readSourceData ()

Static Public Member Functions
static void	unpinChunk (Chunk &chunk)

Protected Member Functions
void	createChunkScratchBuffer (Chunk_NS::Chunk &chunk)
void	freeChunkScratchBuffer (Chunk_NS::Chunk &chunk)

Protected Attributes
int	device_id_
const ChunkKey &	chunk_key_prefix_
Fragmenter_Namespace::FragmentInfo *	fragment_info_
const ColumnDescriptor *	src_cd_
const ColumnDescriptor *	dst_cd_
const size_t	num_elements_
Data_Namespace::DataMgr *	data_mgr_
Catalog_Namespace::Catalog *	catalog_
std::map< int, Chunk_NS::Chunk > &	column_map_
data_conversion::ConversionFactoryParam	param_
std::unique_ptr < data_conversion::BaseSource >	source
AbstractBuffer *	buffer_
AbstractBuffer *	index_buffer_
Chunk_NS::Chunk	disk_level_src_chunk_
Chunk_NS::Chunk	mem_level_src_chunk_
ChunkKey	key_
const int8_t *	src_data_
ArrayElemTypeChunk	scalar_temp_chunk_

Detailed Description

Definition at line 121 of file InsertOrderFragmenter.cpp.

Constructor & Destructor Documentation

Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::BaseAlterColumnContext ( int  device_id, const ChunkKey &  chunk_key_prefix, Fragmenter_Namespace::FragmentInfo *  fragment_info, const ColumnDescriptor *  src_cd, const ColumnDescriptor *  dst_cd, const size_t  num_elements, Data_Namespace::DataMgr *  data_mgr, Catalog_Namespace::Catalog *  catalog, std::map< int, Chunk_NS::Chunk > &  column_map  )

inline

Definition at line 123 of file InsertOrderFragmenter.cpp.

      : device_id_(device_id)
      , chunk_key_prefix_(chunk_key_prefix)
      , fragment_info_(fragment_info)
      , src_cd_(src_cd)
      , dst_cd_(dst_cd)
      , num_elements_(num_elements)
      , data_mgr_(data_mgr)
      , catalog_(catalog)
      , column_map_(column_map)
      , buffer_(nullptr)
      , index_buffer_(nullptr)
      , disk_level_src_chunk_{src_cd}
      , mem_level_src_chunk_{src_cd} {
    key_ = get_chunk_key(chunk_key_prefix, src_cd->columnId, fragment_info->fragmentId);
  }

Member Function Documentation

void Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::createChunkScratchBuffer ( Chunk_NS::Chunk &  chunk )

inlineprotected

Definition at line 188 of file InsertOrderFragmenter.cpp.

References ColumnDescriptor::columnType, Data_Namespace::CPU_LEVEL, data_mgr_(), Chunk_NS::Chunk::getColumnDesc(), SQLTypeInfo::is_varlen_indeed(), Chunk_NS::Chunk::setBuffer(), and Chunk_NS::Chunk::setIndexBuffer().

                                                      {
    chunk.setBuffer(data_mgr_->alloc(MemoryLevel::CPU_LEVEL, 0, 0));
    if (chunk.getColumnDesc()->columnType.is_varlen_indeed()) {
      chunk.setIndexBuffer(data_mgr_->alloc(MemoryLevel::CPU_LEVEL, 0, 0));
    }
  }

Here is the call graph for this function:

void Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::freeChunkScratchBuffer ( Chunk_NS::Chunk &  chunk )

inlineprotected

Definition at line 195 of file InsertOrderFragmenter.cpp.

References ColumnDescriptor::columnType, data_mgr_(), Chunk_NS::Chunk::getBuffer(), Chunk_NS::Chunk::getColumnDesc(), Chunk_NS::Chunk::getIndexBuf(), SQLTypeInfo::is_varlen_indeed(), Chunk_NS::Chunk::setBuffer(), and Chunk_NS::Chunk::setIndexBuffer().

                                                    {
    data_mgr_->free(chunk.getBuffer());
    chunk.setBuffer(nullptr);
    if (chunk.getColumnDesc()->columnType.is_varlen_indeed()) {
      data_mgr_->free(chunk.getIndexBuf());
      chunk.setIndexBuffer(nullptr);
    }
  }

Here is the call graph for this function:

void Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::readSourceData ( )

inline

Definition at line 162 of file InsertOrderFragmenter.cpp.

References CHECK_EQ, Data_Namespace::CPU_LEVEL, data_conversion::create_source(), data_mgr_(), and Data_Namespace::DISK_LEVEL.

                        {
    disk_level_src_chunk_.getChunkBuffer(
        data_mgr_, key_, Data_Namespace::MemoryLevel::DISK_LEVEL, device_id_);
    // FIXME: there appears to be a bug where if the `num_elements` is not specified
    // below, the wrong byte count is returned for index buffers
    mem_level_src_chunk_.getChunkBuffer(data_mgr_,
                                        key_,
                                        MemoryLevel::CPU_LEVEL,
                                        0,
                                        disk_level_src_chunk_.getBuffer()->size(),
                                        num_elements_);
    CHECK_EQ(num_elements_,
             mem_level_src_chunk_.getBuffer()->getEncoder()->getNumElems());

    auto db_id = catalog_->getDatabaseId();
    source = data_conversion::create_source(mem_level_src_chunk_, db_id);

    try {
      std::tie(src_data_, std::ignore) = source->getSourceData();
    } catch (std::exception& except) {
      src_data_ = nullptr;
      throw std::runtime_error("Column " + src_cd_->columnName + ": " + except.what());
    }
  }

Here is the call graph for this function:

static void Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::unpinChunk ( Chunk &  chunk )

inlinestatic

Definition at line 148 of file InsertOrderFragmenter.cpp.

References Chunk_NS::Chunk::getBuffer(), Chunk_NS::Chunk::getIndexBuf(), Chunk_NS::Chunk::setBuffer(), Chunk_NS::Chunk::setIndexBuffer(), and Data_Namespace::AbstractBuffer::unPin().

                                       {
    auto buffer = chunk.getBuffer();
    if (buffer) {
      buffer->unPin();
      chunk.setBuffer(nullptr);
    }

    auto index_buffer = chunk.getIndexBuf();
    if (index_buffer) {
      index_buffer->unPin();
      chunk.setIndexBuffer(nullptr);
    }
  }

Here is the call graph for this function:

Member Data Documentation

AbstractBuffer* Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::buffer_

protected

Definition at line 216 of file InsertOrderFragmenter.cpp.

Catalog_Namespace::Catalog* Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::catalog_

protected

Definition at line 211 of file InsertOrderFragmenter.cpp.

const ChunkKey& Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::chunk_key_prefix_

protected

Definition at line 205 of file InsertOrderFragmenter.cpp.

std::map<int, Chunk_NS::Chunk>& Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::column_map_

protected

Definition at line 212 of file InsertOrderFragmenter.cpp.

Data_Namespace::DataMgr* Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::data_mgr_

protected

Definition at line 210 of file InsertOrderFragmenter.cpp.

int Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::device_id_

protected

Definition at line 204 of file InsertOrderFragmenter.cpp.

Chunk_NS::Chunk Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::disk_level_src_chunk_

protected

Definition at line 218 of file InsertOrderFragmenter.cpp.

const ColumnDescriptor* Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::dst_cd_

protected

Definition at line 208 of file InsertOrderFragmenter.cpp.

Fragmenter_Namespace::FragmentInfo* Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::fragment_info_

protected

Definition at line 206 of file InsertOrderFragmenter.cpp.

AbstractBuffer* Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::index_buffer_

protected

Definition at line 217 of file InsertOrderFragmenter.cpp.

ChunkKey Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::key_

protected

Definition at line 220 of file InsertOrderFragmenter.cpp.

Chunk_NS::Chunk Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::mem_level_src_chunk_

protected

Definition at line 219 of file InsertOrderFragmenter.cpp.

const size_t Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::num_elements_

protected

Definition at line 209 of file InsertOrderFragmenter.cpp.

data_conversion::ConversionFactoryParam Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::param_

protected

Definition at line 214 of file InsertOrderFragmenter.cpp.

ArrayElemTypeChunk Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::scalar_temp_chunk_

protected

Definition at line 222 of file InsertOrderFragmenter.cpp.

std::unique_ptr<data_conversion::BaseSource> Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::source

protected

Definition at line 215 of file InsertOrderFragmenter.cpp.

const ColumnDescriptor* Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::src_cd_

protected

Definition at line 207 of file InsertOrderFragmenter.cpp.

const int8_t* Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext::src_data_

protected

Definition at line 221 of file InsertOrderFragmenter.cpp.

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/Fragmenter/InsertOrderFragmenter.cpp