map() 函数

map() 遍历输入行并将函数应用于它们。

每个输入行都作为记录 r 传递给 fn。每个 r 属性代表一个列键值对。 输出值必须是以下支持的列类型：

• float
• 整数
• 无符号整数
• string
• boolean
• time

输出数据

输出表是将 map 函数 (fn) 应用于输入表的每个记录的结果。 输出记录根据输入流的组键分配到新表。 如果输出记录包含组键列的不同值，则该记录将重新分组到相应的表中。 如果输出记录删除组键列，则该列将从组键中删除。

保留列

map() 删除任何未通过列标签显式映射的列，或使用 fn 函数中的 with 运算符隐式映射的列。 如果 with 运算符已存在记录属性，则更新该属性；如果不存在，则创建新的记录属性，并将所有现有属性包含在输出记录中。

data
    |> map(fn: (r) => ({ r with newColumn: r._value * 2 }))

函数类型签名

(<-tables: stream[A], fn: (r: A) => B, ?mergeKey: bool) => stream[B]

参数

fn

（必需）应用于每个记录的单参数函数。 返回值必须是记录。

mergeKey

(已弃用) 合并映射记录的组键。 默认为 false。

tables

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

示例

• 将每行中的值平方
• 创建一个包含新列的新表
• 添加新列并保留现有列

将每行中的值平方

import "sampledata"

sampledata.int()
    |> map(fn: (r) => ({r with _value: r._value * r._value}))

创建一个包含新列的新表

import "sampledata"

sampledata.int()
    |> map(
        fn: (r) => ({time: r._time, source: r.tag, alert: if r._value > 10 then true else false}),
    )

添加新列并保留现有列

在 r 记录上使用 with 运算符来保留未通过 map 操作直接操作的列。

import "sampledata"

sampledata.int()
    |> map(fn: (r) => ({r with server: "server-${r.tag}", valueFloat: float(v: r._value)}))