ArrayValueConverter< ELEMENT_CONVERTER > Struct Template Reference

#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
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 450 of file TargetValueConvertersImpl.h.

Constructor & Destructor Documentation

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 462 of file TargetValueConvertersImpl.h.

References ArrayValueConverter< ELEMENT_CONVERTER >::allocateColumnarData().

      : 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);
    }
  }

Here is the call graph for this function:

template<typename ELEMENT_CONVERTER >

ArrayValueConverter< ELEMENT_CONVERTER >::~ArrayValueConverter ( )

inlineoverride

Definition at line 475 of file TargetValueConvertersImpl.h.

{}

Member Function Documentation

template<typename ELEMENT_CONVERTER >

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

inlineoverridevirtual

Implements TargetValueConverter.

Definition at line 524 of file TargetValueConvertersImpl.h.

References DataBlockPtr::arraysPtr, ArrayValueConverter< ELEMENT_CONVERTER >::column_data_, TargetValueConverter::column_descriptor_, ColumnDescriptor::columnId, Fragmenter_Namespace::InsertData::columnIds, Fragmenter_Namespace::InsertData::data, and ArrayValueConverter< ELEMENT_CONVERTER >::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:

template<typename ELEMENT_CONVERTER >

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

inlineoverridevirtual

Implements TargetValueConverter.

Definition at line 477 of file TargetValueConvertersImpl.h.

References CHECK(), ArrayValueConverter< ELEMENT_CONVERTER >::column_buffer_, ArrayValueConverter< ELEMENT_CONVERTER >::column_data_, and num_rows.

Referenced by ArrayValueConverter< ELEMENT_CONVERTER >::ArrayValueConverter().

                                                      {
    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);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename ELEMENT_CONVERTER >

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

inlineoverridevirtual

Implements TargetValueConverter.

Definition at line 485 of file TargetValueConvertersImpl.h.

References ArrayValueConverter< ELEMENT_CONVERTER >::ARRAY_VALUE_ACCESSOR, CHECK(), ArrayValueConverter< ELEMENT_CONVERTER >::column_buffer_, ArrayValueConverter< ELEMENT_CONVERTER >::element_converter_, and anonymous_namespace{TypedDataAccessors.h}::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 (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 {
      // TODO: what does it mean if do_check_null_ is set to false and we get a NULL?
      // CHECK(do_check_null_);  // May need to check
      bool is_null = true;  // do_check_null_;
      (*column_data_)[row] = ArrayDatum(0, nullptr, is_null, DoNothingDeleter());
      (*column_data_)[row].is_null = is_null;
    }
  }

Here is the call graph for this function:

template<typename ELEMENT_CONVERTER >

void ArrayValueConverter< ELEMENT_CONVERTER >::finalizeDataBlocksForInsertData ( )

inlineoverridevirtual

Reimplemented from TargetValueConverter.

Definition at line 517 of file TargetValueConvertersImpl.h.

References ArrayValueConverter< ELEMENT_CONVERTER >::column_buffer_, ArrayValueConverter< ELEMENT_CONVERTER >::column_data_, ArrayValueConverter< ELEMENT_CONVERTER >::data_finalized_, and ArrayValueConverter< ELEMENT_CONVERTER >::element_converter_.

Referenced by ArrayValueConverter< ELEMENT_CONVERTER >::addDataBlocksToInsertData().

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

Here is the caller graph for this function:

Member Data Documentation

template<typename ELEMENT_CONVERTER >

boost_variant_accessor<ArrayTargetValue> ArrayValueConverter< ELEMENT_CONVERTER >::ARRAY_VALUE_ACCESSOR

Definition at line 460 of file TargetValueConvertersImpl.h.

Referenced by ArrayValueConverter< ELEMENT_CONVERTER >::convertToColumnarFormat().

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 453 of file TargetValueConvertersImpl.h.

Referenced by ArrayValueConverter< ELEMENT_CONVERTER >::allocateColumnarData(), ArrayValueConverter< ELEMENT_CONVERTER >::convertToColumnarFormat(), and ArrayValueConverter< ELEMENT_CONVERTER >::finalizeDataBlocksForInsertData().

template<typename ELEMENT_CONVERTER >

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

Definition at line 454 of file TargetValueConvertersImpl.h.

Referenced by ArrayValueConverter< ELEMENT_CONVERTER >::addDataBlocksToInsertData(), ArrayValueConverter< ELEMENT_CONVERTER >::allocateColumnarData(), and ArrayValueConverter< ELEMENT_CONVERTER >::finalizeDataBlocksForInsertData().

template<typename ELEMENT_CONVERTER >

bool ArrayValueConverter< ELEMENT_CONVERTER >::data_finalized_ = false

Definition at line 458 of file TargetValueConvertersImpl.h.

Referenced by ArrayValueConverter< ELEMENT_CONVERTER >::finalizeDataBlocksForInsertData().

template<typename ELEMENT_CONVERTER >

bool ArrayValueConverter< ELEMENT_CONVERTER >::do_check_null_

Definition at line 457 of file TargetValueConvertersImpl.h.

template<typename ELEMENT_CONVERTER >

std::unique_ptr<ELEMENT_CONVERTER> ArrayValueConverter< ELEMENT_CONVERTER >::element_converter_

Definition at line 455 of file TargetValueConvertersImpl.h.

Referenced by ArrayValueConverter< ELEMENT_CONVERTER >::convertToColumnarFormat(), and ArrayValueConverter< ELEMENT_CONVERTER >::finalizeDataBlocksForInsertData().

template<typename ELEMENT_CONVERTER >

SQLTypeInfo ArrayValueConverter< ELEMENT_CONVERTER >::element_type_info_

Definition at line 456 of file TargetValueConvertersImpl.h.

---

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

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