OmniSciDB  c0231cc57d
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
Public Attributes | List of all members
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...
 
std::vector< bool > is_default
 

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 68 of file Fragmenter.h.

Member Data Documentation

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

identifies the table into which the data is being inserted

Definition at line 71 of file Fragmenter.h.

Referenced by Fragmenter_Namespace::InsertOrderFragmenter::addColumns(), 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(), GeoMultiPointValueConverter::addDataBlocksToInsertData(), GeoLinestringValueConverter::addDataBlocksToInsertData(), GeoMultiLinestringValueConverter::addDataBlocksToInsertData(), GeoPolygonValueConverter::addDataBlocksToInsertData(), GeoMultiPolygonValueConverter::addDataBlocksToInsertData(), Fragmenter_Namespace::computeRowIndicesOfShards(), Fragmenter_Namespace::copyDataOfShard(), RelAlgExecutor::executeSimpleInsert(), import_export::fill_missing_columns(), import_export::Loader::init(), DBHandler::insert_data(), Fragmenter_Namespace::InsertOrderFragmenter::insertDataImpl(), Fragmenter_Namespace::InsertOrderFragmenter::isAddingNewColumns(), import_export::Loader::loadToShard(), Fragmenter_Namespace::SortedOrderFragmenter::sortData(), and Fragmenter_Namespace::InsertOrderFragmenter::updateColumns().

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

the number of rows being inserted

Definition at line 73 of file Fragmenter.h.

Referenced by Fragmenter_Namespace::InsertOrderFragmenter::addColumns(), 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(), GeoMultiPointValueConverter::addDataBlocksToInsertData(), GeoLinestringValueConverter::addDataBlocksToInsertData(), GeoMultiLinestringValueConverter::addDataBlocksToInsertData(), GeoPolygonValueConverter::addDataBlocksToInsertData(), GeoMultiPolygonValueConverter::addDataBlocksToInsertData(), Fragmenter_Namespace::computeRowIndicesOfShards(), Fragmenter_Namespace::copyDataOfShard(), RelAlgExecutor::executeSimpleInsert(), import_export::fill_missing_columns(), DBHandler::insert_data(), Fragmenter_Namespace::InsertOrderFragmenter::insertDataImpl(), import_export::Loader::loadToShard(), heavydb.thrift.ttypes.TColumn::read(), heavydb.thrift.ttypes.TInsertData::read(), heavydb.thrift.ttypes.TInsertChunks::read(), Fragmenter_Namespace::SortedOrderFragmenter::sortData(), heavydb.thrift.ttypes.TColumn::write(), heavydb.thrift.ttypes.TInsertData::write(), and heavydb.thrift.ttypes.TInsertChunks::write().

int Fragmenter_Namespace::InsertData::databaseId

Definition at line 69 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().

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

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

Definition at line 75 of file Fragmenter.h.

Referenced by Fragmenter_Namespace::computeRowIndicesOfShards(), Fragmenter_Namespace::copyDataOfShard(), import_export::fill_missing_columns(), DBHandler::insert_data(), Fragmenter_Namespace::InsertOrderFragmenter::insertDataImpl(), import_export::Loader::loadToShard(), heavydb.thrift.ttypes.TInsertData::read(), Fragmenter_Namespace::SortedOrderFragmenter::sortData(), Fragmenter_Namespace::InsertOrderFragmenter::updateColumns(), and heavydb.thrift.ttypes.TInsertData::write().

size_t Fragmenter_Namespace::InsertData::numRows

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

Definition at line 72 of file Fragmenter.h.

Referenced by Fragmenter_Namespace::InsertOrderFragmenter::addColumns(), Fragmenter_Namespace::computeRowIndicesOfShards(), Fragmenter_Namespace::copyDataOfShard(), RelAlgExecutor::executeSimpleInsert(), import_export::Loader::init(), DBHandler::insert_data(), Fragmenter_Namespace::InsertDataLoader::insertData(), Fragmenter_Namespace::InsertOrderFragmenter::insertDataImpl(), import_export::Loader::loadToShard(), Parser::InsertIntoTableAsSelectStmt::populateData(), Fragmenter_Namespace::SortedOrderFragmenter::sortData(), and Fragmenter_Namespace::InsertOrderFragmenter::updateColumns().

int Fragmenter_Namespace::InsertData::tableId

identifies the database into which the data is being inserted

Definition at line 70 of file Fragmenter.h.

Referenced by Fragmenter_Namespace::computeRowIndicesOfShards(), Fragmenter_Namespace::copyDataOfShard(), RelAlgExecutor::executeSimpleInsert(), import_export::fill_missing_columns(), import_export::Loader::init(), DBHandler::insert_data(), Fragmenter_Namespace::InsertDataLoader::insertData(), Fragmenter_Namespace::InsertOrderFragmenter::insertData(), Fragmenter_Namespace::LocalInsertConnector::insertDataToLeaf(), Parser::InsertIntoTableAsSelectStmt::populateData(), and Fragmenter_Namespace::InsertOrderFragmenter::updateColumns().

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