Spark-编程进阶（Scala版）

累加器 累加器提供了将工做节点中的值聚合到驱动器程序中的简单语法。累加器的一个常见用法是在调测时对做业执行过程当中的时间进行计数。java 例：累加空行算法 val sc = new SparkContext() val file = sc.textFile("file.txt") val blankLines = sc.accumulator(0)//建立Accumulator[Int]并初始化

>>阅读原文<<