Yes, feel free to open a [MINOR] PR to fix that. On Sun, Nov 27, 2016 at 5:34 PM Anton Okolnychyi <okolnychyyan...@gmail.com> wrote:
> 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 >