主要介绍了Spark累加器的相关内容，首先介绍了累加器的简单使用，然后向大家分享了自定义累加器的实例代码，需要的朋友可以参考下。

累加器（accumulator）是Spark中提供的一种分布式的变量机制，其原理类似于mapreduce，即分布式的改变，然后聚合这些改变。累加器的一个常见用途是在调试时对作业执行过程中的事件进行计数。 累加器简单使用 Spark内置的提供了Long和Double类型的累加器。下面是一个简单的使用示例，在这个例子中我们在过滤掉RDD中奇数的同时进行计数，最后计算剩下整数的和。 val sparkConf = new SparkConf().setAppName(Test).setMaste