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