dask.bag.Bag.reduction
dask.bag.Bag.reduction¶
- Bag.reduction(perpartition, aggregate, split_every=None, out_type=<class 'dask.bag.core.Item'>, name=None)[源代码]¶
使用归约运算符减少集合。
- 参数
- perpartition: 函数
应用于每个分区的缩减操作
- aggregate: 函数
应用于所有分区结果的归约操作
- split_every: int (可选)
在进行归约时，将分区分组为该大小的组。默认值为8
- out_type: {Bag, Item}
结果的输出类型，如果是单个元素则为 Item，如果是元素列表则为 Bag。默认为 Item。
示例
>>> import dask.bag as db >>> b = db.from_sequence(range(10)) >>> b.reduction(sum, sum).compute() 45