group() 函数
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()
此页是否对您有帮助？
感谢您的反馈！