Fragmenter_Namespace::InsertData Struct Reference

The data to be inserted using the fragment manager. More...

#include <Fragmenter.h>

Public Attributes
int	databaseId
int	tableId
	identifies the database into which the data is being inserted More...
std::vector< int >	columnIds
	identifies the table into which the data is being inserted More...
size_t	numRows
	a vector of column ids for the row(s) being inserted More...
std::vector< DataBlockPtr >	data
	the number of rows being inserted More...
int64_t	replicate_count
std::vector< bool >	bypass
	count to replicate values of column(s); used only for ALTER ADD column More...
std::map< int, const ColumnDescriptor * >	columnDescriptors

Detailed Description

The data to be inserted using the fragment manager.

The data being inserted is assumed to be in columnar format, and so the offset to the beginning of each column can be calculated by multiplying the column size by the number of rows.

Todo:

support for variable-length data types

Definition at line 59 of file Fragmenter.h.

Member Data Documentation

std::vector<bool> Fragmenter_Namespace::InsertData::bypass

count to replicate values of column(s); used only for ALTER ADD column

Definition at line 68 of file Fragmenter.h.

Referenced by Importer_NS::Loader::loadToShard(), and Fragmenter_Namespace::InsertOrderFragmenter::replicateData().

std::map<int, const ColumnDescriptor*> Fragmenter_Namespace::InsertData::columnDescriptors

Definition at line 69 of file Fragmenter.h.

Referenced by Fragmenter_Namespace::InsertOrderFragmenter::insertDataImpl(), Importer_NS::Loader::loadToShard(), and Fragmenter_Namespace::InsertOrderFragmenter::replicateData().

std::vector<int> Fragmenter_Namespace::InsertData::columnIds

identifies the table into which the data is being inserted

Definition at line 62 of file Fragmenter.h.

Referenced by NumericValueConverter< int64_t, TARGET_TYPE >::addDataBlocksToInsertData(), Fragmenter_Namespace::ScalarChunkConverter< BUFFER_DATA_TYPE, INSERT_DATA_TYPE >::addDataBlocksToInsertData(), Fragmenter_Namespace::FixedLenArrayChunkConverter::addDataBlocksToInsertData(), Fragmenter_Namespace::StringChunkConverter::addDataBlocksToInsertData(), Fragmenter_Namespace::DateChunkConverter< BUFFER_DATA_TYPE >::addDataBlocksToInsertData(), DictionaryValueConverter< TARGET_TYPE >::addDataBlocksToInsertData(), StringValueConverter::addDataBlocksToInsertData(), ArrayValueConverter< ELEMENT_CONVERTER >::addDataBlocksToInsertData(), GeoPointValueConverter::addDataBlocksToInsertData(), GeoLinestringValueConverter::addDataBlocksToInsertData(), GeoPolygonValueConverter::addDataBlocksToInsertData(), GeoMultiPolygonValueConverter::addDataBlocksToInsertData(), Fragmenter_Namespace::computeRowIndicesOfShards(), Fragmenter_Namespace::copyDataOfShard(), Executor::executeSimpleInsert(), Importer_NS::Loader::init(), MapDHandler::insert_data(), Fragmenter_Namespace::InsertOrderFragmenter::insertDataImpl(), Fragmenter_Namespace::InsertOrderFragmenter::replicateData(), and Fragmenter_Namespace::SortedOrderFragmenter::sortData().

std::vector<DataBlockPtr> Fragmenter_Namespace::InsertData::data

the number of rows being inserted

Definition at line 64 of file Fragmenter.h.

Referenced by NumericValueConverter< int64_t, TARGET_TYPE >::addDataBlocksToInsertData(), Fragmenter_Namespace::ScalarChunkConverter< BUFFER_DATA_TYPE, INSERT_DATA_TYPE >::addDataBlocksToInsertData(), Fragmenter_Namespace::FixedLenArrayChunkConverter::addDataBlocksToInsertData(), Fragmenter_Namespace::StringChunkConverter::addDataBlocksToInsertData(), Fragmenter_Namespace::DateChunkConverter< BUFFER_DATA_TYPE >::addDataBlocksToInsertData(), DictionaryValueConverter< TARGET_TYPE >::addDataBlocksToInsertData(), StringValueConverter::addDataBlocksToInsertData(), ArrayValueConverter< ELEMENT_CONVERTER >::addDataBlocksToInsertData(), GeoPointValueConverter::addDataBlocksToInsertData(), GeoLinestringValueConverter::addDataBlocksToInsertData(), GeoPolygonValueConverter::addDataBlocksToInsertData(), GeoMultiPolygonValueConverter::addDataBlocksToInsertData(), Fragmenter_Namespace::computeRowIndicesOfShards(), Fragmenter_Namespace::copyDataOfShard(), Executor::executeSimpleInsert(), MapDHandler::insert_data(), Fragmenter_Namespace::InsertOrderFragmenter::insertDataImpl(), Importer_NS::Loader::loadToShard(), Fragmenter_Namespace::InsertOrderFragmenter::replicateData(), and Fragmenter_Namespace::SortedOrderFragmenter::sortData().

int Fragmenter_Namespace::InsertData::databaseId

Definition at line 60 of file Fragmenter.h.

Referenced by Fragmenter_Namespace::copyDataOfShard(), Executor::executeSimpleInsert(), Importer_NS::Loader::init(), MapDHandler::insert_data(), Fragmenter_Namespace::InsertOrderFragmenter::insertData(), Parser::InsertIntoTableAsSelectStmt::populateData(), and Fragmenter_Namespace::InsertOrderFragmenter::updateColumns().

size_t Fragmenter_Namespace::InsertData::numRows

a vector of column ids for the row(s) being inserted

Definition at line 63 of file Fragmenter.h.

Referenced by Fragmenter_Namespace::computeRowIndicesOfShards(), Fragmenter_Namespace::copyDataOfShard(), Executor::executeSimpleInsert(), Importer_NS::Loader::init(), MapDHandler::insert_data(), Fragmenter_Namespace::InsertOrderFragmenter::insertDataImpl(), Importer_NS::Loader::loadToShard(), Parser::InsertIntoTableAsSelectStmt::populateData(), Fragmenter_Namespace::InsertOrderFragmenter::replicateData(), Fragmenter_Namespace::SortedOrderFragmenter::sortData(), and Fragmenter_Namespace::InsertOrderFragmenter::updateColumns().

int64_t Fragmenter_Namespace::InsertData::replicate_count

Initial value:

=
      0

points to the start of the data block per column for the row(s) being inserted

Definition at line 66 of file Fragmenter.h.

Referenced by Fragmenter_Namespace::InsertOrderFragmenter::insertDataImpl(), and Importer_NS::Loader::loadToShard().

int Fragmenter_Namespace::InsertData::tableId

identifies the database into which the data is being inserted

Definition at line 61 of file Fragmenter.h.

Referenced by Fragmenter_Namespace::computeRowIndicesOfShards(), Fragmenter_Namespace::copyDataOfShard(), Executor::executeSimpleInsert(), Importer_NS::Loader::init(), MapDHandler::insert_data(), Fragmenter_Namespace::InsertDataLoader::insertData(), Fragmenter_Namespace::InsertOrderFragmenter::insertData(), Parser::InsertIntoTableAsSelectStmt::LocalConnector::insertDataToLeaf(), Parser::InsertIntoTableAsSelectStmt::populateData(), and Fragmenter_Namespace::InsertOrderFragmenter::updateColumns().

---

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

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