mvt_agg_transfn()

void mvt_agg_transfn

(

mvt_agg_context *

ctx

)

Aggregation step.

Expands features array if needed by a factor of 2. Allocates a new feature, increment feature counter and encode geometry and properties into it.  

Definition at line 1005 of file mvt.c.

{
        bool isnull = false;
        Datum datum;
        GSERIALIZED *gs;
        LWGEOM *lwgeom;
        VectorTile__Tile__Feature *feature;
        VectorTile__Tile__Layer *layer = ctx->layer;
/*      VectorTile__Tile__Feature **features = layer->features; */
        POSTGIS_DEBUG(2, "mvt_agg_transfn called");
 
        if (layer->n_features >= ctx->features_capacity)
        {
                size_t new_capacity = ctx->features_capacity * 2;
                layer->features = repalloc(layer->features, new_capacity *
                        sizeof(*layer->features));
                ctx->features_capacity = new_capacity;
                POSTGIS_DEBUGF(3, "mvt_agg_transfn new_capacity: %zd", new_capacity);
        }
 
        if (ctx->geom_index == UINT32_MAX)
                parse_column_keys(ctx);
 
        datum = GetAttributeByNum(ctx->row, ctx->geom_index + 1, &isnull);
        POSTGIS_DEBUGF(3, "mvt_agg_transfn ctx->geom_index: %d", ctx->geom_index);
        POSTGIS_DEBUGF(3, "mvt_agg_transfn isnull: %u", isnull);
        POSTGIS_DEBUGF(3, "mvt_agg_transfn datum: %lu", datum);
        if (isnull) /* Skip rows that have null geometry */
        {
                POSTGIS_DEBUG(3, "mvt_agg_transfn got null geom");
                return;
        }
 
        feature = palloc(sizeof(*feature));
        vector_tile__tile__feature__init(feature);
 
        ctx->feature = feature;
 
        gs = (GSERIALIZED *) PG_DETOAST_DATUM(datum);
        lwgeom = lwgeom_from_gserialized(gs);
 
        POSTGIS_DEBUGF(3, "mvt_agg_transfn encoded feature count: %zd", layer->n_features);
        layer->features[layer->n_features++] = feature;
 
        encode_geometry(ctx, lwgeom);
        lwgeom_free(lwgeom);
        // TODO: free detoasted datum?
        parse_values(ctx);
}

References encode_geometry(), mvt_agg_context::feature, mvt_agg_context::features_capacity, mvt_agg_context::geom_index, mvt_agg_context::layer, lwgeom_free(), lwgeom_from_gserialized(), parse_column_keys(), parse_values(), mvt_agg_context::row, and UINT32_MAX.

Referenced by pgis_asmvt_transfn().

Here is the call graph for this function:

Here is the caller graph for this function: