#include <TargetValueConvertersImpl.h>

Inheritance diagram for StringValueConverter:

Collaboration diagram for StringValueConverter:

Public Member Functions
	StringValueConverter (const ColumnDescriptor cd, size_t num_rows, bool dictEncoded, const shared::StringDictKey &source_dict_key, StringDictionaryProxy literals_dict)

	~StringValueConverter () override

void	allocateColumnarData (size_t num_rows) override

void	convertToColumnarFormatFromDict (size_t row, const TargetValue *value)

void	convertToColumnarFormatFromString (size_t row, const TargetValue *value)

void	convertToColumnarFormat (size_t row, const TargetValue *value) override

void	addDataBlocksToInsertData (Fragmenter_Namespace::InsertData &insertData) override

Public Member Functions inherited from TargetValueConverter
	TargetValueConverter (const ColumnDescriptor *cd)

virtual	~TargetValueConverter ()

virtual void	finalizeDataBlocksForInsertData ()

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

boost_variant_accessor< int64_t >	SOURCE_TYPE_ACCESSOR

StringDictionary *	source_dict_

StringDictionaryProxy *	literals_source_dict_

bool	dict_encoded_

Public Attributes inherited from TargetValueConverter
const ColumnDescriptor *	column_descriptor_

boost_variant_accessor < ScalarTargetValue >	SCALAR_TARGET_VALUE_ACCESSOR

boost_variant_accessor < ArrayTargetValue >	ARRAY_TARGET_VALUE_ACCESSOR

boost_variant_accessor < GeoTargetValue >	GEO_TARGET_VALUE_ACCESSOR

boost_variant_accessor < NullableString >	NULLABLE_STRING_ACCESSOR

boost_variant_accessor < std::string >	STRING_ACCESSOR

Detailed Description

Definition at line 418 of file TargetValueConvertersImpl.h.

Constructor & Destructor Documentation

StringValueConverter::StringValueConverter	(	const ColumnDescriptor *	cd,
		size_t	num_rows,
		bool	dictEncoded,
		const shared::StringDictKey &	source_dict_key,
		StringDictionaryProxy *	literals_dict
	)

inline

Definition at line 427 of file TargetValueConvertersImpl.h.

References allocateColumnarData(), CHECK, shared::StringDictKey::db_id, dict_encoded_, shared::StringDictKey::dict_id, Catalog_Namespace::SysCatalog::getCatalog(), Catalog_Namespace::SysCatalog::instance(), literals_source_dict_, and source_dict_.

       : TargetValueConverter(cd) {
     source_dict_ = nullptr;
     literals_source_dict_ = nullptr;
     dict_encoded_ = dictEncoded;
     if (dictEncoded) {
       if (0 != source_dict_key.dict_id) {
         const auto source_cat =
             Catalog_Namespace::SysCatalog::instance().getCatalog(source_dict_key.db_id);
         CHECK(source_cat);
         const auto source_dict_desc =
             source_cat->getMetadataForDict(std::abs(source_dict_key.dict_id), true);
         CHECK(source_dict_desc);
         source_dict_ = source_dict_desc->stringDict.get();
         CHECK(source_dict_);
       } else {
         literals_source_dict_ = literals_dict;
       }
     }
     if (num_rows) {
       allocateColumnarData(num_rows);
     }
   }

Here is the call graph for this function:

StringValueConverter::~StringValueConverter ( )

inlineoverride

Definition at line 455 of file TargetValueConvertersImpl.h.

455 {}

Member Function Documentation

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

inlineoverridevirtual

Implements TargetValueConverter.

Definition at line 506 of file TargetValueConvertersImpl.h.

References column_data_, TargetValueConverter::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 StringValueConverter::allocateColumnarData ( size_t num_rows )

inlineoverridevirtual

Implements TargetValueConverter.

Definition at line 457 of file TargetValueConvertersImpl.h.

References CHECK, and column_data_.

Referenced by StringValueConverter().

                                                       {
     CHECK(num_rows > 0);
     column_data_ = std::make_unique<std::vector<std::string>>(num_rows);
   }

Here is the caller graph for this function:

void StringValueConverter::convertToColumnarFormat	(	size_t	row,
		const TargetValue *	value
	)

inlineoverridevirtual

Implements TargetValueConverter.

Definition at line 498 of file TargetValueConvertersImpl.h.

References convertToColumnarFormatFromDict(), convertToColumnarFormatFromString(), and dict_encoded_.

                                                                               {
     if (dict_encoded_) {
       convertToColumnarFormatFromDict(row, value);
     } else {
       convertToColumnarFormatFromString(row, value);
     }
   }

Here is the call graph for this function:

void StringValueConverter::convertToColumnarFormatFromDict	(	size_t	row,
		const TargetValue *	value
	)

inline

Definition at line 462 of file TargetValueConvertersImpl.h.

References CHECK_EQ, StringDictionaryProxy::getString(), StringDictionary::getString(), literals_source_dict_, TargetValueConverter::SCALAR_TARGET_VALUE_ACCESSOR, source_dict_, and SOURCE_TYPE_ACCESSOR.

Referenced by convertToColumnarFormat().

                                                                              {
     auto scalarValue =
         checked_get<ScalarTargetValue>(row, value, SCALAR_TARGET_VALUE_ACCESSOR);
     auto db_p = checked_get<int64_t>(row, scalarValue, this->SOURCE_TYPE_ACCESSOR);
     auto val = *db_p;
 
     if (std::numeric_limits<int32_t>::min() == val) {
       (*column_data_)[row] = std::string("");
     } else {
       if (source_dict_) {
         std::string strVal = source_dict_->getString(val);
         (*column_data_)[row] = strVal;
       } else if (literals_source_dict_) {
         std::string strVal = literals_source_dict_->getString(val);
         (*column_data_)[row] = strVal;
       } else {
         CHECK_EQ(val, inline_int_null_value<int32_t>());
         std::string nullStr = "";
         (*column_data_)[row] = nullStr;
       }
     }
   }

Here is the call graph for this function:

Here is the caller graph for this function:

void StringValueConverter::convertToColumnarFormatFromString	(	size_t	row,
		const TargetValue *	value
	)

inline

Definition at line 485 of file TargetValueConvertersImpl.h.

References TargetValueConverter::NULLABLE_STRING_ACCESSOR, TargetValueConverter::SCALAR_TARGET_VALUE_ACCESSOR, and TargetValueConverter::STRING_ACCESSOR.

Referenced by convertToColumnarFormat().

                                                                                {
     auto scalarValue =
         checked_get<ScalarTargetValue>(row, value, SCALAR_TARGET_VALUE_ACCESSOR);
     auto db_p = checked_get<NullableString>(row, scalarValue, NULLABLE_STRING_ACCESSOR);
     const auto db_str_p = checked_get<std::string>(row, db_p, STRING_ACCESSOR);
 
     if (nullptr != db_str_p) {
       (*column_data_)[row] = *db_str_p;
     } else {
       (*column_data_)[row] = std::string("");
     }
   }