dask.bag.Item

dask.bag.Item

class dask.bag.Item(dsk, key, layer=None)[源代码]
__init__(dsk, key, layer=None)[源代码]

方法

__init__(dsk, key[, layer])

apply(func)

compute(**kwargs)

计算这个 dask 集合

from_delayed(value)

从 dask.delayed 值创建包项。

persist(**kwargs)

将此 dask 集合持久化到内存中

to_delayed([optimize_graph])

转换为一个 dask.delayed 对象。

visualize([filename, format, optimize_graph])

使用 graphviz 渲染此对象任务图的计算。