geo.groupByArea() function

The geo.groupByArea() function groups rows by geographic area. Area sizes are determined by the specified level. Each geographic area is assigned a unique identifier which is stored in the newColumn. Results are grouped by newColumn.

import "experimental/geo"

geo.groupByArea(
    newColumn: "geoArea",
    level: 3,
    s2cellIDLevel: -1,
)

Parameters

newColumn

Name of the new column that stores the unique identifier for a geographic area.

level

S2 Cell level used to determine the size of each geographic area.

s2cellIDLevel

S2 Cell level used in s2_cell_id tag. Default is -1.

tables

Input data. Default is piped-forward data (<-).

Examples

import "experimental/geo"

region = {minLat: 40.51757813, maxLat: 40.86914063, minLon: -73.65234375, maxLon: -72.94921875}

from(bucket: "example-bucket")
    |> range(start: -1h)
    |> filter(fn: (r) => r._measurement == "example-measurement")
    |> geo.gridFilter(region: region)
    |> geo.toRows()
    |> geo.groupByArea(newColumn: "geoArea", level: 3)