Hi guys,

I am looking at the Accumulator section in the latest programming guide.
Is there a typo in the sample code? Shouldn't the add() method accept only
one param in Spark 2.0? It looks like the signature is inherited
from AccumulatorParam, which was there before.

object VectorAccumulatorV2 extends AccumulatorV2[MyVector, MyVector] {
  val vec_ : MyVector = MyVector.createZeroVector
  def reset(): MyVector = {
    vec_.reset()
  }
  def add(v1: MyVector, v2: MyVector): MyVector = {
    vec_.add(v2)
  }
  ...}


Sincerely,
Anton

Reply via email to