dask.bag.Bag.filter

dask.bag.Bag.filter¶

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

根据谓词函数过滤集合中的元素。

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

>>> import dask.bag as db
>>> b = db.from_sequence(range(5))
>>> list(b.filter(iseven))
[0, 2, 4]

dask.bag.Bag.distinct

dask.bag.Bag.flatten