scala - 如何在火花中读取工作任务中累加器的值？
问题描述
根据 spark 中累加器的文档：
请注意，工作节点上的任务无法访问累加器的 value()——从这些任务的角度来看，累加器是只写变量。这使得累加器可以有效地实现，而不必每次更新都进行通信。
累加器是工作节点的只写变量。
有什么方法可以读取工作节点中的累加器值并将其值用于某些业务逻辑？
解决方案
推荐阅读
- .htaccess - .htaccess 从 url 中删除多个参数
- javascript - EmberJS Octane 将焦点放在元素上
- flask - sqlalchemy多对多关联表不插入行
- java - 使用 Java 收集所有 VersionOne 资产及其所有属性
- c++ - 在 ComboBox 编辑中设置焦点时如何显示下拉列表？
- c# - 故事板动画没有动画
- node.js - 获取 Socket IO 服务器的状态
- asp.net-web-api - Asp.net WebAPI 令牌返回 unicode 编码
- php - 在 Godaddy 服务器中未找到“ZipArchive”类 Laravel phpword
- c - 忽略c中的“默认”函数