#include <TargetValueConvertersImpl.h>

Inheritance diagram for GeoMultiPointValueConverter:

Collaboration diagram for GeoMultiPointValueConverter:

Public Member Functions
	GeoMultiPointValueConverter (const Catalog_Namespace::Catalog &cat, size_t num_rows, const ColumnDescriptor *logicalColumnDescriptor)

	~GeoMultiPointValueConverter () override

void	allocateColumnarData (size_t num_rows) override

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

void	addDataBlocksToInsertData (Fragmenter_Namespace::InsertData &insertData) override

Public Member Functions inherited from GeoPointValueConverter
	GeoPointValueConverter (const Catalog_Namespace::Catalog &cat, size_t num_rows, const ColumnDescriptor *logicalColumnDescriptor)

	~GeoPointValueConverter () override

ArrayDatum	toCompressedCoords (const std::shared_ptr< std::vector< double >> &coords)

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

virtual	~TargetValueConverter ()

virtual void	finalizeDataBlocksForInsertData ()

Public Attributes
const ColumnDescriptor *	bounds_column_descriptor_

std::unique_ptr< std::vector < ArrayDatum > >	bounds_data_

boost_variant_accessor < GeoMultiPointTargetValue >	GEO_MULTIPOINT_VALUE_ACCESSOR

Public Attributes inherited from GeoPointValueConverter
const ColumnDescriptor *	coords_column_descriptor_

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

std::unique_ptr< std::vector < ArrayDatum > >	signed_compressed_coords_data_

boost_variant_accessor < GeoTargetValue >	GEO_VALUE_ACCESSOR

boost_variant_accessor < GeoPointTargetValue >	GEO_POINT_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

Definition at line 743 of file TargetValueConvertersImpl.h.

Constructor & Destructor Documentation

GeoMultiPointValueConverter::GeoMultiPointValueConverter	(	const Catalog_Namespace::Catalog &	cat,
		size_t	num_rows,
		const ColumnDescriptor *	logicalColumnDescriptor
	)

inline

Definition at line 748 of file TargetValueConvertersImpl.h.

References allocateColumnarData(), bounds_column_descriptor_, CHECK, TargetValueConverter::column_descriptor_, ColumnDescriptor::columnId, Catalog_Namespace::Catalog::getMetadataForColumn(), and ColumnDescriptor::tableId.

       : GeoPointValueConverter(cat, num_rows, logicalColumnDescriptor) {
     bounds_column_descriptor_ = cat.getMetadataForColumn(
         column_descriptor_->tableId, column_descriptor_->columnId + 2);
     CHECK(bounds_column_descriptor_);
 
     if (num_rows) {
       allocateColumnarData(num_rows);
     }
   }

Here is the call graph for this function:

GeoMultiPointValueConverter::~GeoMultiPointValueConverter ( )

inlineoverride

Definition at line 761 of file TargetValueConvertersImpl.h.

761 {}

Member Function Documentation

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

inlineoverridevirtual

Reimplemented from GeoPointValueConverter.

Definition at line 796 of file TargetValueConvertersImpl.h.

References GeoPointValueConverter::addDataBlocksToInsertData(), DataBlockPtr::arraysPtr, bounds_column_descriptor_, bounds_data_, ColumnDescriptor::columnId, Fragmenter_Namespace::InsertData::columnIds, and Fragmenter_Namespace::InsertData::data.

                                                                                       {
     GeoPointValueConverter::addDataBlocksToInsertData(insertData);
 
     DataBlockPtr bounds;
 
     bounds.arraysPtr = bounds_data_.get();
 
     insertData.data.emplace_back(bounds);
     insertData.columnIds.emplace_back(bounds_column_descriptor_->columnId);
   }

Here is the call graph for this function:

void GeoMultiPointValueConverter::allocateColumnarData ( size_t num_rows )

inlineoverridevirtual

Reimplemented from GeoPointValueConverter.

Definition at line 763 of file TargetValueConvertersImpl.h.

References GeoPointValueConverter::allocateColumnarData(), bounds_data_, and CHECK.

Referenced by GeoMultiPointValueConverter().

                                                       {
     CHECK(num_rows > 0);
     GeoPointValueConverter::allocateColumnarData(num_rows);
     bounds_data_ = std::make_unique<std::vector<ArrayDatum>>(num_rows);
   }

Here is the call graph for this function:

Here is the caller graph for this function:

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

inlineoverridevirtual

Reimplemented from GeoPointValueConverter.

Definition at line 771 of file TargetValueConvertersImpl.h.

References CHECK, compute_bounds_of_coords(), GEO_MULTIPOINT_VALUE_ACCESSOR, TargetValueConverter::GEO_TARGET_VALUE_ACCESSOR, NULL_ARRAY_DOUBLE, NULL_DOUBLE, to_array_datum(), and GeoPointValueConverter::toCompressedCoords().

                                                                               {
     const auto geoValue =
         checked_get<GeoTargetValue>(row, value, GEO_TARGET_VALUE_ACCESSOR);
     CHECK(geoValue);
     if (geoValue->is_initialized()) {
       const auto geo = geoValue->get();
       const auto geoMultiPoint =
           checked_get<GeoMultiPointTargetValue>(row, &geo, GEO_MULTIPOINT_VALUE_ACCESSOR);
 
       (*column_data_)[row] = "";
       (*signed_compressed_coords_data_)[row] = toCompressedCoords(geoMultiPoint->coords);
       auto bounds = compute_bounds_of_coords(geoMultiPoint->coords);
       (*bounds_data_)[row] = to_array_datum(bounds);
     } else {
       // NULL MultiPoint
       (*column_data_)[row] = "";
       (*signed_compressed_coords_data_)[row] = ArrayDatum(0, nullptr, true);
       std::vector<double> bounds = {
           NULL_ARRAY_DOUBLE, NULL_DOUBLE, NULL_DOUBLE, NULL_DOUBLE};
       auto bounds_datum = to_array_datum(bounds);
       bounds_datum.is_null = true;
       (*bounds_data_)[row] = bounds_datum;
     }
   }

Here is the call graph for this function:

Member Data Documentation

const ColumnDescriptor* GeoMultiPointValueConverter::bounds_column_descriptor_

Definition at line 744 of file TargetValueConvertersImpl.h.

Referenced by addDataBlocksToInsertData(), and GeoMultiPointValueConverter().

std::unique_ptr<std::vector<ArrayDatum> > GeoMultiPointValueConverter::bounds_data_

Definition at line 746 of file TargetValueConvertersImpl.h.

Referenced by addDataBlocksToInsertData(), and allocateColumnarData().

boost_variant_accessor<GeoMultiPointTargetValue> GeoMultiPointValueConverter::GEO_MULTIPOINT_VALUE_ACCESSOR

Definition at line 769 of file TargetValueConvertersImpl.h.

Referenced by convertToColumnarFormat().

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

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

Public Member Functions

Public Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation