#include <OdbcGeospatialEncoder.h>

Inheritance diagram for foreign_storage::OdbcGeospatialEncoder:

Collaboration diagram for foreign_storage::OdbcGeospatialEncoder:

Public Member Functions
	OdbcGeospatialEncoder (std::list< Chunk_NS::Chunk > &chunks, std::list< std::unique_ptr< ChunkMetadata >> &chunk_metadata, const bool is_error_tracking_enabled, const SQLTypeInfo &sql_type_info, const bool geo_validate_geometry)

void	appendData (const std::vector< std::string > &geo_strings, std::optional< std::set< size_t >> &rejected_row_local_indices)

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)

Private Attributes
const SQLTypeInfo	type_info_

const bool	is_error_tracking_enabled_

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 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 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 23 of file OdbcGeospatialEncoder.h.

Constructor & Destructor Documentation

foreign_storage::OdbcGeospatialEncoder::OdbcGeospatialEncoder	(	std::list< Chunk_NS::Chunk > &	chunks,
		std::list< std::unique_ptr< ChunkMetadata >> &	chunk_metadata,
		const bool	is_error_tracking_enabled,
		const SQLTypeInfo &	sql_type_info,
		const bool	geo_validate_geometry
	)

inline

Definition at line 25 of file OdbcGeospatialEncoder.h.

       : GeospatialEncoder(chunks, chunk_metadata, geo_validate_geometry)
       , type_info_(sql_type_info)
       , is_error_tracking_enabled_(is_error_tracking_enabled) {}

Member Function Documentation

void foreign_storage::OdbcGeospatialEncoder::appendData	(	const std::vector< std::string > &	geo_strings,
		std::optional< std::set< size_t >> &	rejected_row_local_indices
	)

inline

Definition at line 34 of file OdbcGeospatialEncoder.h.

References foreign_storage::GeospatialEncoder::appendArrayDatumsToBufferAndUpdateMetadata(), foreign_storage::GeospatialEncoder::appendBaseDataAndUpdateMetadata(), CHECK, foreign_storage::GeospatialEncoder::clearDatumBuffers(), foreign_storage::GeospatialEncoder::clearParseBuffers(), SQLTypeInfo::get_notnull(), is_error_tracking_enabled_, foreign_storage::GeospatialEncoder::processGeoElement(), foreign_storage::GeospatialEncoder::processNullGeoElement(), and type_info_.

                                                                            {
     if (is_error_tracking_enabled_) {
       CHECK(rejected_row_local_indices.has_value());
     }
     clearDatumBuffers();
     int64_t num_rows = geo_strings.size();
     for (int64_t i = 0; i < num_rows; ++i) {
       clearParseBuffers();
       auto const& geo_string = geo_strings[i];
       if (geo_string.size()) {
         try {
           processGeoElement(geo_string);
         } catch (const std::runtime_error& except) {
           if (is_error_tracking_enabled_) {
             rejected_row_local_indices->insert(i);
             clearParseBuffers();
             processNullGeoElement();
           } else {
             throw except;
           }
         }
       } else {
         processNullGeoElement();
         if (is_error_tracking_enabled_ && type_info_.get_notnull()) {
           rejected_row_local_indices->insert(i);
         }
       }
     }
     appendArrayDatumsToBufferAndUpdateMetadata();
     appendBaseDataAndUpdateMetadata(num_rows);
   }

Here is the call graph for this function:

Member Data Documentation

const bool foreign_storage::OdbcGeospatialEncoder::is_error_tracking_enabled_

private

Definition at line 69 of file OdbcGeospatialEncoder.h.

Referenced by appendData().

const SQLTypeInfo foreign_storage::OdbcGeospatialEncoder::type_info_

private

Definition at line 68 of file OdbcGeospatialEncoder.h.

Referenced by appendData().

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

/home/jenkins-slave/workspace/core-os-doxygen/DataMgr/ForeignStorage/OdbcGeospatialEncoder.h

Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation