代码之家 › 专栏 › 技术社区 › Amit Teli

pyspark中的CollectAsync等效项

pyspark asynchronous

Amit Teli · 技术社区 · 7 年前

我需要在集群上的任务中安排一些数据库插入(influxdb.write_points)。 rddpipeline.collect返回延迟的任务。但它就卡在那里了。

有没有类似于CollectAsync的东西?

0 回复 | 直到 7 年前

推荐文章

Niobos · 如何/是否有方法使通用算法函数同时与同步和异步函数一起工作?

3 月前

Rami Dhouib · Flutter:如果等待时间超过2秒,则执行操作

4 月前

Jess The Witch · GCP云功能中处理延迟任务的模式

5 月前

justiceorjustus · Javascript中异步递归函数块内部是否有同步函数调用?

5 月前

Plup · 连接失败时,PyMongo异步客户端未引发异常

6 月前

user1233894 · 尝试从全局函数传递值

6 月前

ZNackasha · 如何将Arc<RwLock<dyn Child>>转换为Arc<RwLock<dyn-Base>>

9 月前

Grigory Turlykin · 发送媒体python电报机器人(ASYNC)

9 月前

Fabiano Taioli · 管理单线程Rust中的阻塞函数

10 月前

river7816 · 为什么spdlog不在async函数中打印

10 月前