Hogyan térképének egy RDD eset osztály LabeledPoint (címke jellemző vektor)

szavazat
27

Hogyan térképének egy RDD eset osztály LabeledPoint (címke jellemző vektor).

Ez az eset RDD osztály vizsga (x: Dupla, y: Double):

Ds (1.0,6.0)

Ds (2.0,8.0)

Ds (3.0,10.0)

Ds (3.0,10.0)

ds (4.0,12.0)

Ds (5.0,14.0)

Próbáltam ezt -

     val parsedData = aRDD.map(row =>
     new LabeledPoint(
     row._1,
     Vectors.dense(row._2))

Első hiba „érték _1 nem tagja a main.scala.spark.Q1Partb.Q1.Exam” a row._1 és row._2

és ez -

          val parsedData = aRDD.map{line => 
          val Array(rawLabel, rawfeatures) = line.split(',')
          val features = rawfeatures) .split(' ').map(_.toDouble)
          LabeledPoint(rawLabel.toDouble, Vectors.dense(features))}

Hibaüzenet jelenik meg: „rekurzív értéke x $ 4 igényeinek típus” a rawLabel és „érték osztott nem tagja a main.scala.spark.Q1Partb.Q1.ds” az line.split ( „”)

A kérdést 03/05/2017 22:53
felhasználó
Más nyelveken...                            


2 válasz

szavazat
1

Ha van egy RDD [Vizsga] akkor képesnek kell lennie arra, hogy írjon

val parsedData = aRDD.map(exam => LabeledPoint(exam.x, Vectors.dense(exam.y))
Válaszolt 04/05/2017 04:59
a forrás felhasználó

szavazat
1

Volt ez a kérdés, mert a változó nevét vette át a funkciót.

Így private val Seq(transaction, transaction2) = insertTx(...

lett

private val Seq(transaction1, transaction2) = insertTx(...

A tranzakció az a tettes.

Válaszolt 09/08/2017 20:15
a forrás felhasználó

Cookies help us deliver our services. By using our services, you agree to our use of cookies. Learn more