Funke (1.6) Densevector.type übernimmt keine Parameter

Question

Ich folge zusammen mit diesem Artikel:

http://learningfrombigdata.com/semantic-similarity-between-sentences-using-apache-spark/

Allerdings, wenn ich zu diesem Teil erhalten:

def distance(lvec: String, rvec: String): Double = { 
    val l = DenseVector(lvec.split(',').map(_.toDouble)) 
    val r = DenseVector(rvec.split(',').map(_.toDouble)) 
    math.sqrt(sum((l - r) :* (l - r))) 
} 

ich der folgende Fehler:

Name: Compile Error 
Message: <console>:177: error: org.apache.spark.mllib.linalg.DenseVector.type does not take parameters 
      val l = DenseVector(lvec.split(',').map(_.toDouble)) 
          ^
<console>:178: error: org.apache.spark.mllib.linalg.DenseVector.type does not take parameters 
      val r = DenseVector(rvec.split(',').map(_.toDouble)) 

Ich vermute, dass es etwas zu tun haben könnte Versionen (ich bin mit Spark-1.6.0), aber ich bin nicht sicher, und war nicht in der Lage viele Informationen über diesen Fehler finden online, jede Hilfe

Answer 1

Fehlende new schätzen würde:

scala> import org.apache.spark.mllib.linalg.DenseVector 
import org.apache.spark.mllib.linalg.DenseVector 

scala> new DenseVector(Array(1, 2, 3)) 
res1: org.apache.spark.mllib.linalg.DenseVector = [1.0,2.0,3.0]