Classes
struct	Point2D

struct	GeoNestedArray

struct	LineString

struct	MultiPoint

struct	MultiLineString

struct	Polygon

struct	MultiPolygon

Functions
DEVICE int32_t	compress_x_coord (const double *x, const int64_t index)

DEVICE int32_t	compress_y_coord (const double *x, const int64_t index)

DEVICE double	decompress_x_coord (const int8_t *data, const int64_t index, const bool is_geoint)

DEVICE double	decompress_y_coord (const int8_t *data, const int64_t index, const bool is_geoint)

DEVICE double	decompress_x_coord (const int8_t *data, const int64_t index, const bool is_geoint, const int32_t input_srid, const int32_t output_srid)

DEVICE double	decompress_y_coord (const int8_t *data, const int64_t index, const bool is_geoint, const int32_t input_srid, const int32_t output_srid)

DEVICE Point2D	get_point (const int8_t *data, const int64_t index, const int32_t input_srid, const int32_t output_srid, const bool is_geoint)

template<typename CT >
void	points_to_vector (const int8_t *points_buf, const int64_t nof_points, const bool is_geoint, std::vector< CT > &result)

std::vector< int32_t >	compress_coords (const int8_t *data, const int64_t size, const bool is_geoint)

std::vector< double >	decompress_coords (const int8_t *data, const int64_t size, const bool is_geoint)

std::vector< int32_t >	compress_coords (const std::vector< double > &coords)

std::vector< double >	decompress_coords (const std::vector< int32_t > &coords)

std::vector< std::vector < int32_t > >	compress_coords (const std::vector< std::vector< double >> &coords)

std::vector< std::vector < double > >	decompress_coords (const std::vector< std::vector< int32_t >> &coords)

std::vector< std::vector < std::vector< int32_t > > >	compress_coords (const std::vector< std::vector< std::vector< double >>> &coords)

std::vector< std::vector < std::vector< double > > >	decompress_coords (const std::vector< std::vector< std::vector< int32_t >>> &coords)

bool	get_is_geoint (const int8_t *flatbuffer)

int32_t	get_input_srid (const int8_t *flatbuffer)

int32_t	get_output_srid (const int8_t *flatbuffer)

Function Documentation

std::vector<int32_t> Geo::compress_coords	(	const int8_t *	data,
		const int64_t	size,
		const bool	is_geoint
	)

inline

Definition at line 1811 of file heavydbTypes.h.

References compress_x_coord(), compress_y_coord(), and run_benchmark_import::result.

Referenced by compress_coords(), and Geo::GeoNestedArray< Point2D >::fromCoordsWorker().

                                                                   {
   int64_t nofpoints = size / (is_geoint ? sizeof(int32_t) * 2 : sizeof(double) * 2);
   std::vector<int32_t> result;
   result.reserve(2 * nofpoints);
   if (is_geoint) {
     const int32_t* buf = reinterpret_cast<const int32_t*>(data);
     result.assign(buf, buf + 2 * nofpoints);
   } else {
     const double* buf = reinterpret_cast<const double*>(data);
     for (int64_t i = 0; i < nofpoints; i++) {
       result.push_back(compress_x_coord(buf, 2 * i));
       result.push_back(compress_y_coord(buf, 2 * i));
     }
   }
   return result;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

std::vector<int32_t> Geo::compress_coords ( const std::vector< double > & coords )

inline

Definition at line 1843 of file heavydbTypes.h.

References compress_x_coord(), compress_y_coord(), and run_benchmark_import::result.

                                                                            {
   std::vector<int32_t> result;
   const size_t nofpoints = coords.size() / 2;
   result.reserve(coords.size());
   const double* buf = coords.data();
   for (size_t i = 0; i < nofpoints; i++) {
     result.push_back(compress_x_coord(buf, 2 * i));
     result.push_back(compress_y_coord(buf, 2 * i));
   }
   return result;
 }

Here is the call graph for this function:

std::vector<std::vector<int32_t> > Geo::compress_coords ( const std::vector< std::vector< double >> & coords )

inline

Definition at line 1867 of file heavydbTypes.h.

References compress_coords(), and run_benchmark_import::result.

                                                 {
   std::vector<std::vector<int32_t>> result;
   result.reserve(coords.size());
   for (size_t i = 0; i < coords.size(); i++) {
     result.push_back(compress_coords(coords[i]));
   }
   return result;
 }

Here is the call graph for this function:

std::vector<std::vector<std::vector<int32_t> > > Geo::compress_coords ( const std::vector< std::vector< std::vector< double >>> & coords )

inline

Definition at line 1887 of file heavydbTypes.h.

References compress_coords(), and run_benchmark_import::result.

                                                            {
   std::vector<std::vector<std::vector<int32_t>>> result;
   result.reserve(coords.size());
   for (size_t i = 0; i < coords.size(); i++) {
     result.push_back(compress_coords(coords[i]));
   }
   return result;
 }

Here is the call graph for this function:

DEVICE int32_t Geo::compress_x_coord	(	const double *	x,
		const int64_t	index
	)

inline

Definition at line 1698 of file heavydbTypes.h.

References Geospatial::compress_longitude_coord_geoint32().

Referenced by compress_coords(), and points_to_vector().

                                                                              {
   return static_cast<int32_t>(Geospatial::compress_longitude_coord_geoint32(x[index]));
 }

Here is the call graph for this function:

Here is the caller graph for this function:

DEVICE int32_t Geo::compress_y_coord	(	const double *	x,
		const int64_t	index
	)

inline

Definition at line 1702 of file heavydbTypes.h.

References Geospatial::compress_latitude_coord_geoint32().

Referenced by compress_coords(), and points_to_vector().

                                                                              {
   return static_cast<int32_t>(Geospatial::compress_latitude_coord_geoint32(x[index + 1]));
 }

Here is the call graph for this function:

Here is the caller graph for this function:

std::vector<double> Geo::decompress_coords	(	const int8_t *	data,
		const int64_t	size,
		const bool	is_geoint
	)

inline

Definition at line 1830 of file heavydbTypes.h.

References decompress_x_coord(), decompress_y_coord(), and run_benchmark_import::result.

Referenced by decompress_coords(), and Geo::GeoNestedArray< Point2D >::fromCoordsWorker().

                                                                    {
   int64_t nofpoints = size / (is_geoint ? sizeof(int32_t) * 2 : sizeof(double) * 2);
   std::vector<double> result;
   result.reserve(2 * nofpoints);
   for (int64_t i = 0; i < nofpoints; i++) {
     result.push_back(decompress_x_coord(data, 2 * i, is_geoint));
     result.push_back(decompress_y_coord(data, 2 * i, is_geoint));
   }
   return result;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

std::vector<double> Geo::decompress_coords ( const std::vector< int32_t > & coords )

inline

Definition at line 1855 of file heavydbTypes.h.

References decompress_x_coord(), decompress_y_coord(), and run_benchmark_import::result.

                                                                              {
   std::vector<double> result;
   const size_t nofpoints = coords.size() / 2;
   result.reserve(coords.size());
   const int8_t* buf = reinterpret_cast<const int8_t*>(coords.data());
   for (size_t i = 0; i < nofpoints; i++) {
     result.push_back(decompress_x_coord(buf, 2 * i, true));
     result.push_back(decompress_y_coord(buf, 2 * i, true));
   }
   return result;
 }

Here is the call graph for this function:

std::vector<std::vector<double> > Geo::decompress_coords ( const std::vector< std::vector< int32_t >> & coords )

inline

Definition at line 1877 of file heavydbTypes.h.

References decompress_coords(), and run_benchmark_import::result.

                                                  {
   std::vector<std::vector<double>> result;
   result.reserve(coords.size());
   for (size_t i = 0; i < coords.size(); i++) {
     result.push_back(decompress_coords(coords[i]));
   }
   return result;
 }

Here is the call graph for this function:

std::vector<std::vector<std::vector<double> > > Geo::decompress_coords ( const std::vector< std::vector< std::vector< int32_t >>> & coords )

inline

Definition at line 1897 of file heavydbTypes.h.

References decompress_coords(), and run_benchmark_import::result.

                                                             {
   std::vector<std::vector<std::vector<double>>> result;
   result.reserve(coords.size());
   for (size_t i = 0; i < coords.size(); i++) {
     result.push_back(decompress_coords(coords[i]));
   }
   return result;
 }

Here is the call graph for this function:

DEVICE double Geo::decompress_x_coord	(	const int8_t *	data,
		const int64_t	index,
		const bool	is_geoint
	)

inline

Definition at line 1706 of file heavydbTypes.h.

References Geospatial::decompress_longitude_coord_geoint32().

Referenced by decompress_coords(), decompress_x_coord(), get_point(), and points_to_vector().

                                                               {
   if (is_geoint) {
     return Geospatial::decompress_longitude_coord_geoint32(
         reinterpret_cast<const int32_t*>(data)[index]);
   } else {
     return reinterpret_cast<const double*>(data)[index];
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

DEVICE double Geo::decompress_x_coord	(	const int8_t *	data,
		const int64_t	index,
		const bool	is_geoint,
		const int32_t	input_srid,
		const int32_t	output_srid
	)

inline

Definition at line 1728 of file heavydbTypes.h.

References decompress_x_coord(), and to_string().

                                                                    {
   double x = decompress_x_coord(data, index, is_geoint);
   if (input_srid == output_srid || output_srid == 0) {
     return x;
   } else if (input_srid == 4326 && output_srid == 900913) {
     // WGS 84 --> Web Mercator
     x *= 111319.490778;
   } else {
 #ifndef __CUDACC__
     throw std::runtime_error("decompress_x_coord: unhandled geo transformation from " +
                              std::to_string(input_srid) + " to " +
                              std::to_string(output_srid) + '.');
 #endif
   }
   return x;
 }

Here is the call graph for this function:

DEVICE double Geo::decompress_y_coord	(	const int8_t *	data,
		const int64_t	index,
		const bool	is_geoint
	)

inline

Definition at line 1717 of file heavydbTypes.h.

References Geospatial::decompress_latitude_coord_geoint32().

Referenced by decompress_coords(), decompress_y_coord(), get_point(), and points_to_vector().

                                                               {
   if (is_geoint) {
     return Geospatial::decompress_latitude_coord_geoint32(
         reinterpret_cast<const int32_t*>(data)[index + 1]);
   } else {
     return reinterpret_cast<const double*>(data)[index + 1];
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

DEVICE double Geo::decompress_y_coord	(	const int8_t *	data,
		const int64_t	index,
		const bool	is_geoint,
		const int32_t	input_srid,
		const int32_t	output_srid
	)

inline

Definition at line 1749 of file heavydbTypes.h.

References decompress_y_coord(), and to_string().

                                                                    {
   double y = decompress_y_coord(data, index, is_geoint);
   if (input_srid == output_srid || output_srid == 0) {
     return y;
   } else if (input_srid == 4326 && output_srid == 900913) {
     // WGS 84 --> Web Mercator
     y = 6378136.99911 * log(tan(.00872664626 * y + .785398163397));
   } else {
 #ifndef __CUDACC__
     throw std::runtime_error("decompress_y_coord: unhandled geo transformation from " +
                              std::to_string(input_srid) + " to " +
                              std::to_string(output_srid) + '.');
 #endif
   }
   return y;
 }

Here is the call graph for this function:

int32_t Geo::get_input_srid ( const int8_t * flatbuffer )

inline

Definition at line 1926 of file heavydbTypes.h.

References GeoPointFormatId, and toString().

Referenced by Analyzer::GeoConstant::add_cast(), and Column< GeoPoint >::getItem().

                                                         {
   FlatBufferManager m{const_cast<int8_t*>(flatbuffer)};
   switch (m.format()) {
     case GeoPointFormatId:
       return m.getGeoPointMetadata()->input_srid;
     default:
 #ifndef __CUDACC__
       throw std::runtime_error("get_input_srid: unexpected format " +
                                ::toString(m.format()));
 #else
       return -1;
 #endif
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

bool Geo::get_is_geoint ( const int8_t * flatbuffer )

inline

Definition at line 1910 of file heavydbTypes.h.

References GeoPointFormatId, and toString().

Referenced by Column< GeoPoint >::getItem().

                                                     {
   FlatBufferManager m{const_cast<int8_t*>(flatbuffer)};
   switch (m.format()) {
     case GeoPointFormatId:
       return m.getGeoPointMetadata()->is_geoint;
     default:
 #ifndef __CUDACC__
       throw std::runtime_error("get_is_geoint: unexpected format " +
                                ::toString(m.format()));
 #else
       return false;
 #endif
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

int32_t Geo::get_output_srid ( const int8_t * flatbuffer )

inline

Definition at line 1942 of file heavydbTypes.h.

References GeoPointFormatId, and toString().

Referenced by Column< GeoPoint >::getItem().

                                                          {
   FlatBufferManager m{const_cast<int8_t*>(flatbuffer)};
   switch (m.format()) {
     case GeoPointFormatId:
       return m.getGeoPointMetadata()->output_srid;
     default:
 #ifndef __CUDACC__
       throw std::runtime_error("get_output_srid: unexpected format " +
                                ::toString(m.format()));
 #else
       return -1;
 #endif
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

DEVICE Point2D Geo::get_point	(	const int8_t *	data,
		const int64_t	index,
		const int32_t	input_srid,
		const int32_t	output_srid,
		const bool	is_geoint
	)

inline

Definition at line 1770 of file heavydbTypes.h.

References decompress_x_coord(), and decompress_y_coord().

Referenced by Column< GeoPoint >::getItem(), and Geo::GeoNestedArray< Point2D >::getPoint().

                                                       {
   Point2D point{decompress_x_coord(data, index, is_geoint, input_srid, output_srid),
                 decompress_y_coord(data, index, is_geoint, input_srid, output_srid)};
   return point;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename CT >

void Geo::points_to_vector	(	const int8_t *	points_buf,
		const int64_t	nof_points,
		const bool	is_geoint,
		std::vector< CT > &	result
	)

inline

Definition at line 1783 of file heavydbTypes.h.

References compress_x_coord(), compress_y_coord(), decompress_x_coord(), and decompress_y_coord().

Referenced by Geo::GeoNestedArray< Point2D >::toCoordsWorker().

                                                     {
   result.reserve(2 * nof_points);
   if (is_geoint) {
     if constexpr (std::is_same<CT, double>::value) {
       for (int64_t i = 0; i < nof_points; i++) {
         result.push_back(decompress_x_coord(points_buf, 2 * i, is_geoint));
         result.push_back(decompress_y_coord(points_buf, 2 * i, is_geoint));
       }
     } else {
       const int32_t* buf = reinterpret_cast<const int32_t*>(points_buf);
       result.assign(buf, buf + 2 * nof_points);
     }
   } else {
     const double* buf = reinterpret_cast<const double*>(points_buf);
     if constexpr (std::is_same<CT, double>::value) {
       result.assign(buf, buf + 2 * nof_points);
     } else {
       for (int64_t i = 0; i < nof_points; i++) {
         result.push_back(compress_x_coord(buf, 2 * i));
         result.push_back(compress_y_coord(buf, 2 * i));
       }
     }
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

Classes

Functions

Function Documentation