dask.bag.from_delayed

dask.bag.from_delayed¶

dask.bag.from_delayed(values)[源代码]¶

从多个 dask Delayed 对象创建 bag。

这些对象将成为结果 Bag 的分区。它们应该评估为一个 list 或其他具体的序列。

参数

返回

参见

示例

>>> x, y, z = [delayed(load_sequence_from_file)(fn)
...             for fn in filenames] 
>>> b = from_delayed([x, y, z])  

dask.bag.from_sequence

dask.bag.from_url