dask.bag.Bag.remove

dask.bag.Bag.remove¶

Bag.remove(predicate)[源代码]¶

移除集合中符合谓词的元素。

>>> def iseven(x):
...     return x % 2 == 0

>>> import dask.bag as db
>>> b = db.from_sequence(range(5))
>>> list(b.remove(iseven))
[1, 3]

dask.bag.Bag.随机抽样

dask.bag.Bag.repartition