ray.data.grouped_data.GroupedData.aggregate

GroupedData.aggregate(*aggs: AggregateFn) → Dataset

实现了一个基于累加器的聚合。

参数:

aggs – 待完成的聚合。

返回:

输出是一个包含 n + 1 列的数据集，其中第一列是分组键，第二列到第 n + 1 列是聚合的结果。如果分组键是 None，则返回结果中省略键部分。