#include <TargetValueConvertersImpl.h>

Inheritance diagram for ArrayValueConverter< ELEMENT_CONVERTER >:

Collaboration diagram for ArrayValueConverter< ELEMENT_CONVERTER >:

Public Member Functions
	ArrayValueConverter (const ColumnDescriptor *cd, size_t num_rows, std::unique_ptr< ELEMENT_CONVERTER > element_converter, bool do_check_null)

	~ArrayValueConverter () override

void	allocateColumnarData (size_t num_rows) override

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

void	finalizeDataBlocksForInsertData () override

void	addDataBlocksToInsertData (Fragmenter_Namespace::InsertData &insertData) override

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

virtual	~TargetValueConverter ()

Public Attributes
std::unique_ptr< std::vector< std::pair< size_t, typename ELEMENT_CONVERTER::ElementsBufferColumnPtr > > >	column_buffer_

std::unique_ptr< std::vector< ArrayDatum > >	column_data_

std::unique_ptr< ELEMENT_CONVERTER >	element_converter_

SQLTypeInfo	element_type_info_

bool	do_check_null_

bool	data_finalized_ = false

int8_t *	fixed_array_null_sentinel_

size_t	fixed_array_size_

size_t	fixed_array_elements_count_

boost_variant_accessor< ArrayTargetValue >	ARRAY_VALUE_ACCESSOR

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

template<typename ELEMENT_CONVERTER>
struct ArrayValueConverter< ELEMENT_CONVERTER >

Definition at line 506 of file TargetValueConvertersImpl.h.

Constructor & Destructor Documentation

◆ ArrayValueConverter()

template<typename ELEMENT_CONVERTER >

ArrayValueConverter< ELEMENT_CONVERTER >::ArrayValueConverter	(	const ColumnDescriptor *	cd,
		size_t	num_rows,
		std::unique_ptr< ELEMENT_CONVERTER >	element_converter,
		bool	do_check_null
	)

inline

Definition at line 521 of file TargetValueConvertersImpl.h.

References NumericValueConverter< SOURCE_TYPE, TARGET_TYPE >::allocateColumnarData(), ColumnDescriptor::columnType, and SQLTypeInfo::get_size().

       : TargetValueConverter(cd)
       , element_converter_(std::move(element_converter))
       , element_type_info_(cd->columnType.get_elem_type())
       , do_check_null_(do_check_null) {
     if (num_rows) {
       allocateColumnarData(num_rows);
     }
 
     if (cd->columnType.get_size() > 0) {
       fixed_array_size_ = cd->columnType.get_size();
       fixed_array_elements_count_ =
           fixed_array_size_ / sizeof(ELEMENT_CONVERTER::fixed_array_null_value_);
       element_converter_->populateFixedArrayNullSentinel(fixed_array_elements_count_);
       fixed_array_null_sentinel_ =
           reinterpret_cast<int8_t*>(element_converter_->column_data_.get());
     } else {
       fixed_array_size_ = 0;
       fixed_array_elements_count_ = 0;
       fixed_array_null_sentinel_ = nullptr;
     }
   }

Here is the call graph for this function:

◆ ~ArrayValueConverter()

template<typename ELEMENT_CONVERTER >

ArrayValueConverter< ELEMENT_CONVERTER >::~ArrayValueConverter ( )

inlineoverride

Definition at line 547 of file TargetValueConvertersImpl.h.

547 {}

Member Function Documentation

◆ addDataBlocksToInsertData()

template<typename ELEMENT_CONVERTER >

void ArrayValueConverter< ELEMENT_CONVERTER >::addDataBlocksToInsertData ( Fragmenter_Namespace::InsertData & insertData )

inlineoverridevirtual

Implements TargetValueConverter.

Definition at line 611 of file TargetValueConvertersImpl.h.

References DataBlockPtr::arraysPtr, TargetValueConverter::column_descriptor_, ColumnDescriptor::columnId, Fragmenter_Namespace::InsertData::columnIds, Fragmenter_Namespace::InsertData::data, and TargetValueConverter::finalizeDataBlocksForInsertData().

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

Here is the call graph for this function:

◆ allocateColumnarData()

template<typename ELEMENT_CONVERTER >

void ArrayValueConverter< ELEMENT_CONVERTER >::allocateColumnarData ( size_t num_rows )

inlineoverridevirtual

Implements TargetValueConverter.

Definition at line 549 of file TargetValueConvertersImpl.h.

References CHECK.

                                                       {
     CHECK(num_rows > 0);
     column_data_ = std::make_unique<std::vector<ArrayDatum>>(num_rows);
     column_buffer_ = std::make_unique<std::vector<
         std::pair<size_t, typename ELEMENT_CONVERTER::ElementsBufferColumnPtr>>>(
         num_rows);
   }

◆ convertToColumnarFormat()

template<typename ELEMENT_CONVERTER >

void ArrayValueConverter< ELEMENT_CONVERTER >::convertToColumnarFormat	(	size_t	row,
		const TargetValue *	value
	)

inlineoverridevirtual

Implements TargetValueConverter.

Definition at line 557 of file TargetValueConvertersImpl.h.

References CHECK, and is_null().

                                                                               {
     const auto arrayValue =
         checked_get<ArrayTargetValue>(row, value, ARRAY_VALUE_ACCESSOR);
     CHECK(arrayValue);
     if (arrayValue->is_initialized()) {
       const auto& vec = arrayValue->get();
       bool is_null = false;
 
       if (fixed_array_elements_count_) {
         if (fixed_array_elements_count_ != vec.size()) {
           throw std::runtime_error(
               "Incorrect number of array elements for fixed length array column");
         }
       }
 
       if (vec.size()) {
         typename ELEMENT_CONVERTER::ElementsBufferColumnPtr elementBuffer =
             element_converter_->allocateColumnarBuffer(vec.size());
 
         int elementIndex = 0;
         for (const auto& scalarValue : vec) {
           element_converter_->convertElementToColumnarFormat(
               elementIndex++, elementBuffer.get(), &scalarValue);
         }
 
         column_buffer_->at(row) = {vec.size(), std::move(elementBuffer)};
 
       } else {
         // Empty, not NULL
         (*column_data_)[row] = ArrayDatum(0, nullptr, is_null, DoNothingDeleter());
       }
     } else {
       if (!do_check_null_) {
         throw std::runtime_error("NULL assignment of non null column not allowed");
       }
 
       if (fixed_array_elements_count_ && !element_converter_->allowFixedNullArray()) {
         throw std::runtime_error("NULL assignment of fixed length array not allowed");
       }
 
       bool is_null = true;  // do_check_null_;
       (*column_data_)[row] = ArrayDatum(
           fixed_array_size_, fixed_array_null_sentinel_, is_null, DoNothingDeleter());
       (*column_data_)[row].is_null = is_null;
     }
   }

Here is the call graph for this function:

◆ finalizeDataBlocksForInsertData()

template<typename ELEMENT_CONVERTER >

void ArrayValueConverter< ELEMENT_CONVERTER >::finalizeDataBlocksForInsertData ( )

inlineoverridevirtual

Reimplemented from TargetValueConverter.

Definition at line 604 of file TargetValueConvertersImpl.h.

                                                   {
     if (!data_finalized_) {
       element_converter_->processArrayBuffer(column_buffer_, column_data_.get());
       data_finalized_ = true;
     }
   }

Member Data Documentation

◆ ARRAY_VALUE_ACCESSOR

template<typename ELEMENT_CONVERTER >

boost_variant_accessor<ArrayTargetValue> ArrayValueConverter< ELEMENT_CONVERTER >::ARRAY_VALUE_ACCESSOR

Definition at line 519 of file TargetValueConvertersImpl.h.

◆ column_buffer_

template<typename ELEMENT_CONVERTER >

std::unique_ptr< std::vector<std::pair<size_t, typename ELEMENT_CONVERTER::ElementsBufferColumnPtr> > > ArrayValueConverter< ELEMENT_CONVERTER >::column_buffer_

Definition at line 509 of file TargetValueConvertersImpl.h.