OmniSciDB
bf83d84833
|
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... | |
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.
Definition at line 59 of file Fragmenter.h.
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 import_export::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 Fragmenter_Namespace::ScalarChunkConverter< BUFFER_DATA_TYPE, INSERT_DATA_TYPE >::addDataBlocksToInsertData(), NumericValueConverter< int64_t, TARGET_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(), RelAlgExecutor::executeSimpleInsert(), import_export::Loader::init(), DBHandler::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 Fragmenter_Namespace::ScalarChunkConverter< BUFFER_DATA_TYPE, INSERT_DATA_TYPE >::addDataBlocksToInsertData(), NumericValueConverter< int64_t, TARGET_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(), RelAlgExecutor::executeSimpleInsert(), DBHandler::insert_data(), Fragmenter_Namespace::InsertOrderFragmenter::insertDataImpl(), import_export::Loader::loadToShard(), omnisci.thrift.ttypes.TColumn::read(), omnisci.thrift.ttypes.TInsertData::read(), Fragmenter_Namespace::InsertOrderFragmenter::replicateData(), Fragmenter_Namespace::SortedOrderFragmenter::sortData(), omnisci.thrift.ttypes.TColumn::write(), and omnisci.thrift.ttypes.TInsertData::write().
int Fragmenter_Namespace::InsertData::databaseId |
Definition at line 60 of file Fragmenter.h.
Referenced by Fragmenter_Namespace::copyDataOfShard(), RelAlgExecutor::executeSimpleInsert(), import_export::Loader::init(), DBHandler::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(), RelAlgExecutor::executeSimpleInsert(), import_export::Loader::init(), DBHandler::insert_data(), Fragmenter_Namespace::InsertOrderFragmenter::insertDataImpl(), import_export::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 |
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 import_export::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(), RelAlgExecutor::executeSimpleInsert(), import_export::Loader::init(), DBHandler::insert_data(), Fragmenter_Namespace::InsertDataLoader::insertData(), Fragmenter_Namespace::InsertOrderFragmenter::insertData(), Parser::LocalConnector::insertDataToLeaf(), Parser::InsertIntoTableAsSelectStmt::populateData(), and Fragmenter_Namespace::InsertOrderFragmenter::updateColumns().