Spark-編程進階（Scala版）

累加器 累加器提供了將工做節點中的值聚合到驅動器程序中的簡單語法。累加器的一個常見用法是在調測時對做業執行過程當中的時間進行計數。java 例：累加空行算法 val sc = new SparkContext() val file = sc.textFile("file.txt") val blankLines = sc.accumulator(0)//建立Accumulator[Int]並初始化

>>阅读原文<<