keyValues() 函数

keyValues() 返回表流，其中每个输入表都包含组键和两列：_key 和 _value，它们对应于每个输入表的唯一列标签和值对。

函数类型签名

(<-tables: stream[A], ?keyColumns: [string]) => stream[{B with _value: C, _key: string}] where A: Record, B: Record

参数

keyColumns

从中提取值的列的列表。

所有列必须是相同类型。每个输入表必须具有 keyColumns 参数中的所有列。

tables

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

示例

从显式定义的列中获取键值

data
    |> keyValues(keyColumns: ["sensorID", "_field"])