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

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

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

Public Member Functions
	GeoAlterColumnContext (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, const std::list< const ColumnDescriptor * > &columns)
void	createScratchBuffers ()
void	deleteScratchBuffers ()
void	encodeData (const bool geo_validate_geometry)
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 ()

Private Attributes
const std::list< const ColumnDescriptor * > &	dst_columns_

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 225 of file InsertOrderFragmenter.cpp.

Constructor & Destructor Documentation

Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::GeoAlterColumnContext::GeoAlterColumnContext ( 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, const std::list< const ColumnDescriptor * > &  columns  )

inline

Definition at line 227 of file InsertOrderFragmenter.cpp.

      : BaseAlterColumnContext(device_id,
                               chunk_key_prefix,
                               fragment_info,
                               src_cd,
                               dst_cd,
                               num_elements,
                               data_mgr,
                               catalog,
                               column_map)
      , dst_columns_(columns) {}

Member Function Documentation

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

inline

Definition at line 248 of file InsertOrderFragmenter.cpp.

                              {
    std::list<Chunk_NS::Chunk>& geo_chunks = param_.geo_chunks;
    std::list<std::unique_ptr<ChunkMetadata>>& chunk_metadata = param_.geo_chunk_metadata;
    // create all geo chunk buffers
    for (auto dst_cd : dst_columns_) {
      geo_chunks.emplace_back(dst_cd, true);
      auto& dst_chunk = geo_chunks.back();

      createChunkScratchBuffer(dst_chunk);
      dst_chunk.initEncoder();

      chunk_metadata.push_back(std::make_unique<ChunkMetadata>());
    }
  }

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

inline

Definition at line 263 of file InsertOrderFragmenter.cpp.

                              {
    for (auto& dst_chunk : param_.geo_chunks) {
      freeChunkScratchBuffer(dst_chunk);
    }
  }

void Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::GeoAlterColumnContext::encodeData ( const bool  geo_validate_geometry )

inline

Definition at line 269 of file InsertOrderFragmenter.cpp.

References data_conversion::create_string_view_encoder().

                                                    {
    auto convert_encoder =
        data_conversion::create_string_view_encoder(param_, false, geo_validate_geometry);
    try {
      convert_encoder->encodeAndAppendData(src_data_, num_elements_);
      convert_encoder->finalize(num_elements_);
    } catch (std::exception& except) {
      throw std::runtime_error("Column " + (*dst_columns_.begin())->columnName + ": " +
                               except.what());
    }
  }

Here is the call graph for this function:

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

inline

Definition at line 281 of file InsertOrderFragmenter.cpp.

References CHECK, data_mgr_(), Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::get_chunk_key(), and Chunk_NS::Chunk::setBuffer().

                          {
    auto metadata_it = param_.geo_chunk_metadata.begin();
    auto chunk_it = param_.geo_chunks.begin();
    for (auto dst_cd : dst_columns_) {
      auto& chunk = *chunk_it;
      auto& metadata = *metadata_it;

      auto encoder = chunk.getBuffer()->getEncoder();
      CHECK(encoder);
      encoder->resetChunkStats(metadata->chunkStats);
      encoder->setNumElems(num_elements_);

      ChunkKey dst_key =
          get_chunk_key(chunk_key_prefix_, dst_cd->columnId, fragment_info_->fragmentId);

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

        chunk.getBuffer()->setUpdated();
        chunk.getIndexBuf()->setUpdated();

        Chunk fragmenter_chunk{dst_cd, false};
        fragmenter_chunk.setBuffer(
            data_mgr_->getGlobalFileMgr()->putBuffer(data_key, chunk.getBuffer()));
        fragmenter_chunk.setIndexBuffer(
            data_mgr_->getGlobalFileMgr()->putBuffer(index_key, chunk.getIndexBuf()));
        column_map_[src_cd_->columnId] = fragmenter_chunk;

      } else {
        chunk.getBuffer()->setUpdated();

        Chunk fragmenter_chunk{dst_cd, false};
        fragmenter_chunk.setBuffer(
            data_mgr_->getGlobalFileMgr()->putBuffer(dst_key, chunk.getBuffer()));
        column_map_[src_cd_->columnId] = fragmenter_chunk;
      }

      chunk_it++;
      metadata_it++;
    }
  }

Here is the call graph for this function:

Member Data Documentation

const std::list<const ColumnDescriptor*>& Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::GeoAlterColumnContext::dst_columns_

private

Definition at line 327 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