怎么样编写系统累加器

1、1）读取文件

2、2）注册累加器

3、3）使用累加器，遇到空行则自增1

4、4）打印RDD中的数量

5、5）打印累加器的值,即文件中的空行数

6、通过在驱动器中调用SparkContext.accumulator(initialValue)方法，创建出存有初始值的累加器。返回值为 or爿讥旌护g.apache.spark.Accumulator[T] 对象，其中 T 是初始值 initialValue 的类型。Spark闭包里的执行器代码可以使用累加器的 += 方法(在Java中是 add)增加累加器的值。 驱动器程序可以调用累加器的value属性(在Java中使用value()或setValue())来访问累加器的值。