8176e19e22
The previous code tried to manually handle resizing the tags array whenever used, but failed to keep it properly sized. This commit adds an abstraction over unfinished features, which enables centralized array size bookkeeping. Closes https://git.osgeo.org/gitea/postgis/postgis/pulls/92 for PostGIS 3.3.0 Closes #5088 for PostGIS 3.3.0
114 lines
3.5 KiB
C
114 lines
3.5 KiB
C
/**********************************************************************
|
|
*
|
|
* PostGIS - Spatial Types for PostgreSQL
|
|
* http://postgis.net
|
|
*
|
|
* PostGIS is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation, either version 2 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* PostGIS is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with PostGIS. If not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
**********************************************************************
|
|
*
|
|
* Copyright (C) 2016-2017 Björn Harrtell <bjorn@wololo.org>
|
|
*
|
|
**********************************************************************/
|
|
|
|
#ifndef MVT_H_
|
|
#define MVT_H_ 1
|
|
|
|
#include <stdlib.h>
|
|
#include "postgres.h"
|
|
#include "utils/builtins.h"
|
|
#include "utils/array.h"
|
|
#include "utils/typcache.h"
|
|
#include "utils/lsyscache.h"
|
|
#include "catalog/pg_type.h"
|
|
#include "catalog/namespace.h"
|
|
#include "executor/executor.h"
|
|
#include "access/htup_details.h"
|
|
#include "access/htup.h"
|
|
#include "../postgis_config.h"
|
|
#include "liblwgeom.h"
|
|
#include "lwgeom_pg.h"
|
|
#include "lwgeom_log.h"
|
|
|
|
#ifdef HAVE_LIBPROTOBUF
|
|
|
|
#include "vector_tile.pb-c.h"
|
|
|
|
typedef struct mvt_column_cache
|
|
{
|
|
uint32_t *column_keys_index;
|
|
uint32_t *column_oid;
|
|
Datum *values;
|
|
bool *nulls;
|
|
TupleDesc tupdesc;
|
|
} mvt_column_cache;
|
|
|
|
typedef struct mvt_agg_context
|
|
{
|
|
/* Temporal memory context using during during pgis_asmvt_transfn and deleted after
|
|
* pgis_asmvt_serialfn. This is to have a faster and simpler way to delete the temporal
|
|
* objects in parallel runs */
|
|
MemoryContext trans_context;
|
|
char *name;
|
|
uint32_t extent;
|
|
|
|
/* Name and position of the property that sets the feature id */
|
|
char *id_name;
|
|
uint32_t id_index;
|
|
|
|
/* Name and position of the property that sets the feature geometry */
|
|
char *geom_name;
|
|
uint32_t geom_index;
|
|
|
|
HeapTupleHeader row;
|
|
/* The layer which stores all the aggregated features. Aggregation can only yield a single layer. */
|
|
VectorTile__Tile__Layer *layer;
|
|
/* The size of the features array in the layer */
|
|
size_t features_capacity;
|
|
/* The cached result of the aggregation. It can only be set once the operation is complete. */
|
|
VectorTile__Tile *tile;
|
|
|
|
/* Hash table holding the feature keys */
|
|
struct mvt_kv_key *keys_hash;
|
|
|
|
/* Hash tables holding the feature values, one per type */
|
|
struct mvt_kv_value *string_values_hash;
|
|
struct mvt_kv_value *float_values_hash;
|
|
struct mvt_kv_value *double_values_hash;
|
|
struct mvt_kv_value *uint_values_hash;
|
|
struct mvt_kv_value *sint_values_hash;
|
|
struct mvt_kv_value *bool_values_hash;
|
|
|
|
/* Total number of values stored (for all combined value hash tables) */
|
|
uint32_t values_hash_i;
|
|
/* Total number of keys stored */
|
|
uint32_t keys_hash_i;
|
|
|
|
mvt_column_cache column_cache;
|
|
} mvt_agg_context;
|
|
|
|
/* Prototypes */
|
|
LWGEOM *mvt_geom(LWGEOM *geom, const GBOX *bounds, uint32_t extent, uint32_t buffer, bool clip_geom);
|
|
void mvt_agg_init_context(mvt_agg_context *ctx);
|
|
void mvt_agg_transfn(mvt_agg_context *ctx);
|
|
bytea *mvt_agg_finalfn(mvt_agg_context *ctx);
|
|
bytea *mvt_ctx_serialize(mvt_agg_context *ctx);
|
|
mvt_agg_context * mvt_ctx_deserialize(const bytea *ba);
|
|
mvt_agg_context * mvt_ctx_combine(mvt_agg_context *ctx1, mvt_agg_context *ctx2);
|
|
|
|
|
|
#endif /* HAVE_LIBPROTOBUF */
|
|
|
|
#endif
|