def accumulator(value, accum_param=:+, zero_value=0)
      Spark::Accumulator.new(value, accum_param, zero_value)
    end
def accumulator(value, accum_param=:+, zero_value=0)
      Spark::Accumulator.new(value, accum_param, zero_value)
    end
Create an Accumulator with the given initial value, using a given
 accum_param helper object to define how to add values of the
 data type if provided.

 == Example:
   accum = $sc.accumulator(7)

   rdd = $sc.parallelize(0..5, 4)
   rdd = rdd.bind(accum: accum)
   rdd = rdd.map_partitions(lambda{|_| accum.add(1) })
   rdd = rdd.collect

   accum.value
   # => 11