如何解压延迟 dask 对象的数据帧?

som*_*mer 1 python pandas dask

我使用了.map_partitions延迟函数,得到的结果是一个数据帧,每行都有延迟结果。

有什么办法可以解压这些延迟的对象吗?难道我做错了什么?

谢谢。

mdu*_*ant 5

一个非常简短的答案:您应该使用map_partitions正常功能,而不是延迟功能。数据帧接口已经提供了惰性和并行性,因此您不需要添加另一个嵌套级别。