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