group() 函数
group()
通过修改输入表的分组键对输入数据进行重新分组。
注意:分组不保证排序顺序。为了确保数据正确排序,请在 group() 后使用 sort()
。
函数类型签名
(<-tables: stream[A], ?columns: [string], ?mode: string) => stream[A] where A: Record
参数
columns
用于分组操作的列列表。默认为 []
。
注意:当 columns
设置为空数组时,group()
将取消所有数据分组,将其合并为单个输出表。
mode
分组模式。默认为 by
。
可用模式:
- by:根据在
columns
参数中定义的列进行分组。 - except:除在
columns
参数中定义的列之外的所有列进行分组。
tables
输入数据。默认为管道传递的数据 (<-
)。
示例
按特定列分组
import "sampledata"
sampledata.int()
|> group(columns: ["_time", "tag"])
除时间外按一切分组
import "sampledata"
sampledata.int()
|> group(columns: ["_time"], mode: "except")
取消分组数据
import "sampledata"
// Merge all tables into a single table
sampledata.int()
|> group()
这个页面有帮助吗?
感谢您的反馈!