Inheritance diagram for Fragmenter_Namespace::StringChunkConverter:

Collaboration diagram for Fragmenter_Namespace::StringChunkConverter:

Public Member Functions
	StringChunkConverter (size_t num_rows, const Chunk_NS::Chunk *chunk)

	~StringChunkConverter () override

void	convertToColumnarFormat (size_t row, size_t indexInFragment) override

void	addDataBlocksToInsertData (Fragmenter_Namespace::InsertData &insertData) override

Public Member Functions inherited from Fragmenter_Namespace::ChunkToInsertDataConverter
virtual	~ChunkToInsertDataConverter ()

Public Attributes
const Chunk_NS::Chunk *	chunk_

const ColumnDescriptor *	column_descriptor_

std::unique_ptr< std::vector < std::string > >	column_data_

const int8_t *	data_buffer_addr_

const StringOffsetT *	index_buffer_addr_

Detailed Description

Definition at line 202 of file UpdelStorage.cpp.

Constructor & Destructor Documentation

Fragmenter_Namespace::StringChunkConverter::StringChunkConverter	(	size_t	num_rows,
		const Chunk_NS::Chunk *	chunk
	)

inline

Definition at line 210 of file UpdelStorage.cpp.

References column_data_, data_buffer_addr_, Chunk_NS::Chunk::getBuffer(), Chunk_NS::Chunk::getIndexBuf(), Data_Namespace::AbstractBuffer::getMemoryPtr(), and index_buffer_addr_.

       : chunk_(chunk), column_descriptor_(chunk->getColumnDesc()) {
     column_data_ = std::make_unique<std::vector<std::string>>(num_rows);
     data_buffer_addr_ = chunk->getBuffer()->getMemoryPtr();
     index_buffer_addr_ =
         (StringOffsetT*)(chunk->getIndexBuf() ? chunk->getIndexBuf()->getMemoryPtr()
                                               : nullptr);
   }

Here is the call graph for this function:

Fragmenter_Namespace::StringChunkConverter::~StringChunkConverter ( )

inlineoverride

Definition at line 219 of file UpdelStorage.cpp.

219 {}

Member Function Documentation

void Fragmenter_Namespace::StringChunkConverter::addDataBlocksToInsertData ( Fragmenter_Namespace::InsertData & insertData )

inlineoverridevirtual

Implements Fragmenter_Namespace::ChunkToInsertDataConverter.

Definition at line 228 of file UpdelStorage.cpp.

References column_data_, column_descriptor_, ColumnDescriptor::columnId, Fragmenter_Namespace::InsertData::columnIds, Fragmenter_Namespace::InsertData::data, and DataBlockPtr::stringsPtr.

                                                                                       {
     DataBlockPtr dataBlock;
     dataBlock.stringsPtr = column_data_.get();
     insertData.data.push_back(dataBlock);
     insertData.columnIds.push_back(column_descriptor_->columnId);
   }

void Fragmenter_Namespace::StringChunkConverter::convertToColumnarFormat	(	size_t	row,
		size_t	indexInFragment
	)

inlineoverridevirtual

Implements Fragmenter_Namespace::ChunkToInsertDataConverter.

Definition at line 221 of file UpdelStorage.cpp.

References data_buffer_addr_, and index_buffer_addr_.

                                                                             {
     size_t src_value_size =
         index_buffer_addr_[indexInFragment + 1] - index_buffer_addr_[indexInFragment];
     auto src_value_ptr = data_buffer_addr_ + index_buffer_addr_[indexInFragment];
     (*column_data_)[row] = std::string((const char*)src_value_ptr, src_value_size);
   }