#include <StringViewToGeoEncoder.h>

Inheritance diagram for data_conversion::StringViewToGeoEncoder:

Collaboration diagram for data_conversion::StringViewToGeoEncoder:

Public Member Functions
	StringViewToGeoEncoder (std::list< Chunk_NS::Chunk > &chunks, std::list< std::unique_ptr< ChunkMetadata >> &chunk_metadata, const bool error_tracking_enabled, const bool geo_validate_geometry)

void	encodeAndAppendData (const int8_t *data, const size_t num_elements) override

Public Member Functions inherited from data_conversion::BaseConvertEncoder
virtual	~BaseConvertEncoder ()

	BaseConvertEncoder (const bool error_tracking_enabled)

void	initializeDeleteBuffer (const size_t size_hint)

virtual void	finalize (const size_t rows_appended)

virtual std::shared_ptr < ChunkMetadata >	getMetadata (const Chunk_NS::Chunk &chunk) const

Public Member Functions inherited from foreign_storage::GeospatialEncoder
virtual	~GeospatialEncoder ()=default

	GeospatialEncoder (const bool geo_validate_geometry)

	GeospatialEncoder (std::list< Chunk_NS::Chunk > &chunks, const bool geo_validate_geometry)

	GeospatialEncoder (std::list< Chunk_NS::Chunk > &chunks, std::list< std::unique_ptr< ChunkMetadata >> &chunk_metadata, const bool geo_validate_geometry)

Additional Inherited Members
Protected Types inherited from foreign_storage::GeospatialEncoder
enum	GeoColumnType { COORDS, BOUNDS, RING_OR_LINE_SIZES, POLY_RINGS }

Protected Member Functions inherited from data_conversion::BaseConvertEncoder
virtual void	clear ()

template<typename DataType >
bool	isNull (const DataType &typed_value)

Protected Member Functions inherited from foreign_storage::GeospatialEncoder
void	appendBaseDataAndUpdateMetadata (const int64_t row_count)

void	validateChunksSizing (std::list< Chunk_NS::Chunk > &chunks) const

void	validateMetadataSizing (std::list< std::unique_ptr< ChunkMetadata >> &chunk_metadata) const

void	appendArrayDatumsToBufferAndUpdateMetadata ()

void	appendToArrayEncoderAndUpdateMetadata (const std::vector< ArrayDatum > &datum_parse_buffer, Encoder encoder, ChunkMetadata chunk_metadata) const

void	processGeoElement (std::string_view geo_string_view)

void	processNullGeoElement ()

void	clearParseBuffers ()

void	clearDatumBuffers ()

template<typename T >
std::list< T >::iterator	getIteratorForGeoColumnType (std::list< T > &list, const SQLTypes column_type, const GeoColumnType geo_column)

std::tuple< Encoder , ChunkMetadata , const ColumnDescriptor * >	initEncoderAndGetEncoderAndMetadata (std::list< Chunk_NS::Chunk > &chunks, std::list< std::unique_ptr< ChunkMetadata >> &chunk_metadata, const SQLTypes sql_type, GeoColumnType geo_column_type)

const ColumnDescriptor *	getColumnDescriptor (std::list< Chunk_NS::Chunk > &chunks, const SQLTypes sql_type, GeoColumnType geo_column_type)

bool	hasBoundsColumn () const

bool	hasRingOrLineSizesColumn () const

bool	hasPolyRingsColumn () const

Static Protected Member Functions inherited from foreign_storage::GeospatialEncoder
static void	throwMalformedGeoElement (const std::string &omnisci_column_name)

static void	throwMismatchedGeoElement (const std::string &omnisci_column_name)

Protected Attributes inherited from data_conversion::BaseConvertEncoder
std::optional< std::vector < bool > >	delete_buffer_

const bool	error_tracking_enabled_

bool	has_nulls_

size_t	num_elements_

Protected Attributes inherited from foreign_storage::GeospatialEncoder
const ColumnDescriptor *	geo_column_descriptor_

StringNoneEncoder *	base_column_encoder_

Encoder *	coords_column_encoder_

Encoder *	bounds_column_encoder_

Encoder *	ring_or_line_sizes_column_encoder_

Encoder *	poly_rings_column_encoder_

ChunkMetadata *	base_column_metadata_

ChunkMetadata *	coords_column_metadata_

ChunkMetadata *	bounds_column_metadata_

ChunkMetadata *	ring_or_line_sizes_column_metadata_

ChunkMetadata *	poly_rings_column_metadata_

const ColumnDescriptor *	coords_column_descriptor_

const ColumnDescriptor *	bounds_column_descriptor_

const ColumnDescriptor *	ring_or_line_sizes_column_descriptor_

const ColumnDescriptor *	poly_rings_column_descriptor_

std::vector< std::string >	base_values_

std::vector< double >	coords_parse_buffer_

std::vector< double >	bounds_parse_buffer_

std::vector< int >	ring_or_line_sizes_parse_buffer_

std::vector< int >	poly_rings_parse_buffer_

std::vector< ArrayDatum >	coords_datum_buffer_

std::vector< ArrayDatum >	bounds_datum_buffer_

std::vector< ArrayDatum >	ring_or_line_sizes_datum_buffer_

std::vector< ArrayDatum >	poly_rings_datum_buffer_

bool	geo_validate_geometry_

Detailed Description

Definition at line 26 of file StringViewToGeoEncoder.h.

Constructor & Destructor Documentation

data_conversion::StringViewToGeoEncoder::StringViewToGeoEncoder	(	std::list< Chunk_NS::Chunk > &	chunks,
		std::list< std::unique_ptr< ChunkMetadata >> &	chunk_metadata,
		const bool	error_tracking_enabled,
		const bool	geo_validate_geometry
	)

inline

Definition at line 29 of file StringViewToGeoEncoder.h.

       : BaseConvertEncoder(error_tracking_enabled)
       , foreign_storage::GeospatialEncoder(chunks,
                                            chunk_metadata,
                                            geo_validate_geometry) {}

Member Function Documentation

void data_conversion::StringViewToGeoEncoder::encodeAndAppendData	(	const int8_t *	data,
		const size_t	num_elements
	)

inlineoverridevirtual

Implements data_conversion::BaseConvertEncoder.

Definition at line 38 of file StringViewToGeoEncoder.h.

References foreign_storage::GeospatialEncoder::appendArrayDatumsToBufferAndUpdateMetadata(), foreign_storage::GeospatialEncoder::appendBaseDataAndUpdateMetadata(), foreign_storage::GeospatialEncoder::clearDatumBuffers(), foreign_storage::GeospatialEncoder::clearParseBuffers(), data_conversion::BaseConvertEncoder::delete_buffer_, data_conversion::BaseConvertEncoder::error_tracking_enabled_, foreign_storage::GeospatialEncoder::processGeoElement(), and foreign_storage::GeospatialEncoder::processNullGeoElement().

                                                                                    {
     auto geo_strings = reinterpret_cast<const std::string_view*>(data);
     clearDatumBuffers();
 
     for (size_t i = 0; i < num_elements; ++i) {
       if (error_tracking_enabled_) {
         delete_buffer_->push_back(false);
       }
       clearParseBuffers();
       auto& geo_string = geo_strings[i];
       if (geo_string.empty()) {
         processNullGeoElement();
       } else {
         try {
           processGeoElement(geo_strings[i]);  // this may throw, need to handle error
         } catch (std::exception& except) {
           if (!error_tracking_enabled_) {
             throw;
           } else {
             clearParseBuffers();
             processNullGeoElement();
             delete_buffer_->back() = true;
           }
         }
       }
     }
 
     appendArrayDatumsToBufferAndUpdateMetadata();
     appendBaseDataAndUpdateMetadata(num_elements);
   }

Here is the call graph for this function:

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

/home/jenkins-slave/workspace/core-os-doxygen/DataMgr/DataConversion/StringViewToGeoEncoder.h

Public Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation