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