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

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

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

Public Member Functions
	NonGeoAlterColumnContext (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	createScratchBuffers ()
void	deleteScratchBuffers ()
void	reencodeData ()
void	putBuffersToDisk ()
Public Member Functions inherited from 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)
void	readSourceData ()

Additional Inherited Members
Static Public Member Functions inherited from Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext
static void	unpinChunk (Chunk &chunk)
Protected Member Functions inherited from Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::BaseAlterColumnContext
void	createChunkScratchBuffer (Chunk_NS::Chunk &chunk)
void	freeChunkScratchBuffer (Chunk_NS::Chunk &chunk)
Protected Attributes inherited from Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::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_
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 330 of file InsertOrderFragmenter.cpp.

Constructor & Destructor Documentation

Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::NonGeoAlterColumnContext::NonGeoAlterColumnContext ( 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 332 of file InsertOrderFragmenter.cpp.

      : BaseAlterColumnContext(device_id,
                               chunk_key_prefix,
                               fragment_info,
                               src_cd,
                               dst_cd,
                               num_elements,
                               data_mgr,
                               catalog_,
                               column_map) {}

Member Function Documentation

void Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::NonGeoAlterColumnContext::createScratchBuffers ( )

inline

Definition at line 351 of file InsertOrderFragmenter.cpp.

References Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::create_array_elem_type_chunk().

                              {
    auto db_id = catalog_->getDatabaseId();
    param_.db_id = db_id;
    param_.dst_chunk = Chunk_NS::Chunk{dst_cd_, true};
    if (dst_cd_->columnType.is_array()) {
      create_array_elem_type_chunk(scalar_temp_chunk_, dst_cd_);
      param_.scalar_temp_chunk = scalar_temp_chunk_.chunk;
    }

    auto& dst_chunk = param_.dst_chunk;

    createChunkScratchBuffer(dst_chunk);

    if (dst_cd_->columnType.is_array()) {
      createChunkScratchBuffer(param_.scalar_temp_chunk);
    }

    buffer_ = dst_chunk.getBuffer();
    index_buffer_ = dst_chunk.getIndexBuf();  // nullptr for non-varlen types
  }

Here is the call graph for this function:

void Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::NonGeoAlterColumnContext::deleteScratchBuffers ( )

inline

Definition at line 372 of file InsertOrderFragmenter.cpp.

                              {
    freeChunkScratchBuffer(param_.dst_chunk);
    if (dst_cd_->columnType.is_array()) {
      freeChunkScratchBuffer(param_.scalar_temp_chunk);
    }
  }

void Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::NonGeoAlterColumnContext::putBuffersToDisk ( )

inline

Definition at line 410 of file InsertOrderFragmenter.cpp.

References data_mgr_(), and Chunk_NS::Chunk::setBuffer().

                          {
    if (dst_cd_->columnType.is_varlen_indeed()) {
      auto data_key = key_;
      data_key.push_back(1);
      auto index_key = key_;
      index_key.push_back(2);

      Chunk fragmenter_chunk{dst_cd_, false};
      fragmenter_chunk.setBuffer(
          data_mgr_->getGlobalFileMgr()->putBuffer(data_key, buffer_));
      fragmenter_chunk.setIndexBuffer(
          data_mgr_->getGlobalFileMgr()->putBuffer(index_key, index_buffer_));
      column_map_[src_cd_->columnId] = fragmenter_chunk;

    } else {
      Chunk fragmenter_chunk{dst_cd_, false};
      fragmenter_chunk.setBuffer(data_mgr_->getGlobalFileMgr()->putBuffer(key_, buffer_));
      column_map_[src_cd_->columnId] = fragmenter_chunk;
    }
  }

Here is the call graph for this function:

void Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::NonGeoAlterColumnContext::reencodeData ( )

inline

Definition at line 379 of file InsertOrderFragmenter.cpp.

References data_conversion::create_string_view_encoder().

                      {
    auto& dst_chunk = param_.dst_chunk;
    disk_level_src_chunk_.getBuffer()->syncEncoder(dst_chunk.getBuffer());
    if (disk_level_src_chunk_.getIndexBuf() && dst_chunk.getIndexBuf()) {
      disk_level_src_chunk_.getIndexBuf()->syncEncoder(dst_chunk.getIndexBuf());
    }

    dst_chunk.initEncoder();

    auto convert_encoder =
        data_conversion::create_string_view_encoder(param_, false, false);  // not geo

    try {
      convert_encoder->encodeAndAppendData(src_data_, num_elements_);
      convert_encoder->finalize(num_elements_);
    } catch (std::exception& except) {
      throw std::runtime_error("Column " + src_cd_->columnName + ": " + except.what());
    }

    auto metadata = convert_encoder->getMetadata(
        dst_cd_->columnType.is_array() ? param_.scalar_temp_chunk : dst_chunk);

    buffer_->getEncoder()->resetChunkStats(metadata->chunkStats);
    buffer_->getEncoder()->setNumElems(num_elements_);

    buffer_->setUpdated();
    if (index_buffer_) {
      index_buffer_->setUpdated();
    }
  }

Here is the call graph for this function:

---

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

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