(The user@ list might be a bit better but I can see why it might look like a dev@ question.)
Did you import org.apache.spark.mllib.linalg.Vector ? I think you are picking up Scala's Vector class instead. On Mon, Jun 9, 2014 at 11:57 AM, dataginjaninja <rickett.stepha...@gmail.com> wrote: > The programming-guide > <http://spark.apache.org/docs/latest/programming-guide.html> has the > following: > > object VectorAccumulatorParam extends AccumulatorParam[Vector] { > def zero(initialValue: Vector): Vector = { > Vector.zeros(initialValue.size) > } > def addInPlace(v1: Vector, v2: Vector): Vector = { > v1 += v2 > } > } > > > // Then, create an Accumulator of this type: > val vecAccum = sc.accumulator(new Vector(...))(VectorAccumulatorParam) > > However, when I try to use this I get an error: > > scala> import org.apache.spark.AccumulatorParam > import org.apache.spark.AccumulatorParam > > scala> object VectorAccumulatorParam extends AccumulatorParam[Vector] { > | def zero(initialValue: Vector): Vector = { > | Vector.zeros(initialValue.size) > | } > | def addInPlace(v1: Vector, v2: Vector): Vector = { > | v1 += v2 > | } > | } > <console>:12: error: type Vector takes type parameters > object VectorAccumulatorParam extends AccumulatorParam[Vector] { > ^ > > > Last thing, am I posting on the wrong list? > > > > ----- > Cheers, > > Stephanie > -- > View this message in context: > http://apache-spark-developers-list.1001551.n3.nabble.com/implementing-the-VectorAccumulatorParam-tp6973.html > Sent from the Apache Spark Developers List mailing list archive at Nabble.com.
