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
>

Reply via email to