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

Question

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

有什么方法可以解压那些延迟的对象吗？ 我做错了什么吗？

谢谢。

Answer 1

一个非常简短的回答：您应该使用具有正常功能的 map_partitions，而不是延迟的功能。 dataframe 接口已经提供惰性和并行性，所以你不需要添加另一个嵌套级别。