geo.groupByArea() 函数

geo.groupByArea() 按地理区域对行进行分组。

区域大小由指定的 level 确定。每个地理区域都分配有一个唯一的标识符（S2 单元 ID 令牌），该标识符存储在 newColumn 中。结果按 newColumn 分组。

函数类型签名

(
    <-tables: stream[{A with s2_cell_id: string, lon: float, lat: float}],
    level: int,
    newColumn: string,
    ?s2cellIDLevel: int,
) => stream[B] where B: Record

参数

newColumn

（必需）用于每个地理区域的唯一标识符的新列的名称。

level

（必需）用于确定每个地理区域大小的 S2 单元级别。

s2cellIDLevel

S2 单元级别，用于 s2_cell_id 标签。默认为 -1（从 s2_cell_id 标签检测 S2 单元级别）。

tables

输入数据。默认为管道转发数据 (<-)。

示例

按地理区域对地理时序数据进行分组

import "experimental/geo"

data
    |> geo.groupByArea(newColumn: "foo", level: 4)