#include <TargetValueConvertersImpl.h>

Inheritance diagram for GeoPointValueConverter:

Collaboration diagram for GeoPointValueConverter:

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

	~GeoPointValueConverter () override

void	allocateColumnarData (size_t num_rows) override

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

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

Constructor & Destructor Documentation

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

inline

Definition at line 629 of file TargetValueConvertersImpl.h.

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

       : TargetValueConverter(logicalColumnDescriptor) {
     coords_column_descriptor_ = cat.getMetadataForColumn(
         column_descriptor_->tableId, column_descriptor_->columnId + 1);
     CHECK(coords_column_descriptor_);
 
     if (num_rows) {
       allocateColumnarData(num_rows);
     }
   }

Here is the call graph for this function:

GeoPointValueConverter::~GeoPointValueConverter ( )

inlineoverride

Definition at line 642 of file TargetValueConvertersImpl.h.

642 {}

Member Function Documentation

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

inlineoverridevirtual

Implements TargetValueConverter.

Reimplemented in GeoMultiPolygonValueConverter, GeoPolygonValueConverter, GeoMultiLinestringValueConverter, GeoLinestringValueConverter, and GeoMultiPointValueConverter.

Definition at line 691 of file TargetValueConvertersImpl.h.

References DataBlockPtr::arraysPtr, column_data_, TargetValueConverter::column_descriptor_, ColumnDescriptor::columnId, Fragmenter_Namespace::InsertData::columnIds, coords_column_descriptor_, Fragmenter_Namespace::InsertData::data, signed_compressed_coords_data_, and DataBlockPtr::stringsPtr.

Referenced by GeoMultiPointValueConverter::addDataBlocksToInsertData(), GeoLinestringValueConverter::addDataBlocksToInsertData(), GeoMultiLinestringValueConverter::addDataBlocksToInsertData(), GeoPolygonValueConverter::addDataBlocksToInsertData(), and GeoMultiPolygonValueConverter::addDataBlocksToInsertData().

                                                                                       {
     DataBlockPtr logical, coords;
 
     logical.stringsPtr = column_data_.get();
     coords.arraysPtr = signed_compressed_coords_data_.get();
 
     insertData.data.emplace_back(logical);
     insertData.columnIds.emplace_back(column_descriptor_->columnId);
 
     insertData.data.emplace_back(coords);
     insertData.columnIds.emplace_back(coords_column_descriptor_->columnId);
   }

Here is the caller graph for this function:

void GeoPointValueConverter::allocateColumnarData ( size_t num_rows )

inlineoverridevirtual

Implements TargetValueConverter.

Reimplemented in GeoMultiPolygonValueConverter, GeoPolygonValueConverter, GeoMultiLinestringValueConverter, GeoLinestringValueConverter, and GeoMultiPointValueConverter.

Definition at line 644 of file TargetValueConvertersImpl.h.

References CHECK, column_data_, and signed_compressed_coords_data_.

Referenced by GeoMultiPointValueConverter::allocateColumnarData(), GeoLinestringValueConverter::allocateColumnarData(), GeoMultiLinestringValueConverter::allocateColumnarData(), GeoPolygonValueConverter::allocateColumnarData(), GeoMultiPolygonValueConverter::allocateColumnarData(), and GeoPointValueConverter().

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

Here is the caller graph for this function:

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

inlineoverridevirtual

Implements TargetValueConverter.

Reimplemented in GeoMultiPolygonValueConverter, GeoPolygonValueConverter, GeoMultiLinestringValueConverter, GeoLinestringValueConverter, and GeoMultiPointValueConverter.

Definition at line 669 of file TargetValueConvertersImpl.h.

References CHECK, GEO_POINT_VALUE_ACCESSOR, GEO_VALUE_ACCESSOR, NULL_ARRAY_DOUBLE, NULL_DOUBLE, and toCompressedCoords().

                                                                               {
     const auto geoValue = checked_get<GeoTargetValue>(row, value, GEO_VALUE_ACCESSOR);
     CHECK(geoValue);
     if (geoValue->is_initialized()) {
       const auto geo = geoValue->get();
       const auto geoPoint =
           checked_get<GeoPointTargetValue>(row, &geo, GEO_POINT_VALUE_ACCESSOR);
       CHECK(geoPoint);
       (*column_data_)[row] = "";
       (*signed_compressed_coords_data_)[row] = toCompressedCoords(geoPoint->coords);
     } else {
       // NULL point
       (*column_data_)[row] = "";
       auto coords = std::make_shared<std::vector<double>>();
       coords->push_back(NULL_ARRAY_DOUBLE);
       coords->push_back(NULL_DOUBLE);
       auto coords_datum = toCompressedCoords(coords);
       coords_datum.is_null = true;
       (*signed_compressed_coords_data_)[row] = coords_datum;
     }
   }

Here is the call graph for this function:

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

inline

Definition at line 653 of file TargetValueConvertersImpl.h.

References checked_malloc(), TargetValueConverter::column_descriptor_, ColumnDescriptor::columnType, and Geospatial::compress_coords().

Referenced by convertToColumnarFormat(), GeoMultiPointValueConverter::convertToColumnarFormat(), GeoLinestringValueConverter::convertToColumnarFormat(), GeoMultiLinestringValueConverter::convertToColumnarFormat(), GeoPolygonValueConverter::convertToColumnarFormat(), and GeoMultiPolygonValueConverter::convertToColumnarFormat().

                                                       {
     const auto compressed_coords_vector =
         Geospatial::compress_coords(*coords, column_descriptor_->columnType);
 
     uint8_t* compressed_coords_array = reinterpret_cast<uint8_t*>(
         checked_malloc(sizeof(uint8_t) * compressed_coords_vector.size()));
     memcpy(compressed_coords_array,
            &compressed_coords_vector[0],
            compressed_coords_vector.size());
 
     return ArrayDatum((int)compressed_coords_vector.size(),
                       reinterpret_cast<int8_t*>(compressed_coords_array),
                       false);
   }

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

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

Definition at line 626 of file TargetValueConvertersImpl.h.

Referenced by addDataBlocksToInsertData(), and allocateColumnarData().

const ColumnDescriptor* GeoPointValueConverter::coords_column_descriptor_

Definition at line 624 of file TargetValueConvertersImpl.h.

Referenced by addDataBlocksToInsertData(), and GeoPointValueConverter().

boost_variant_accessor<GeoPointTargetValue> GeoPointValueConverter::GEO_POINT_VALUE_ACCESSOR

Definition at line 651 of file TargetValueConvertersImpl.h.

Referenced by convertToColumnarFormat().

boost_variant_accessor<GeoTargetValue> GeoPointValueConverter::GEO_VALUE_ACCESSOR

Definition at line 650 of file TargetValueConvertersImpl.h.

Referenced by convertToColumnarFormat().

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

Definition at line 627 of file TargetValueConvertersImpl.h.

Referenced by addDataBlocksToInsertData(), and allocateColumnarData().

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