spark2.x-Accumulator

Accumulator累加器java 累加器（accumulator）是Spark中提供的一种分布式的变量机制，其原理相似于mapreduce，即分布式的改变，而后聚合这些改变。python 累加器的一个常见用途是在调试时对做业执行过程当中的事件进行计数。程序员 Accumulable简单值 结果类型和要合并的元素类型同样， 例如变量仅仅能“添加”到关联和交换操做 因此能在并行程序上有效支持 被用

>>阅读原文<<