0

根据 spark 中累加器的文档:

请注意,工作节点上的任务无法访问累加器的 value()——从这些任务的角度来看,累加器是只写变量。这使得累加器可以有效地实现,而不必每次更新都进行通信。

累加器是工作节点的只写变量。

有什么方法可以读取工作节点中的累加器值并将其值用于某些业务逻辑?

4

0 回答 0