Hoe kan ik een RDD van de zaak klasse toewijzen aan LabeledPoint (label, functie vector)

stemmen
27

Hoe kan ik een RDD van de zaak klasse LabeledPoint (label, functie vector) kaart te brengen.

Dit is de RDD van de zaak klasse Examen (x: Double, 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)

Geprobeerd om dit te doen -

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

Krijg fout value _1 is geen lid van main.scala.spark.Q1Partb.Q1.Exam op row._1 en row._2

en dit -

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

Krijg fout recursieve waarde X-type $ 4 moet voor rawLabel en value split is geen lid van main.scala.spark.Q1Partb.Q1.ds voor line.split ( '')

De vraag is gesteld op 03/05/2017 om 22:53
user
In andere talen...                            


2 antwoorden

stemmen
1

Als u een RDD [examen] moet je in staat om te schrijven

val parsedData = aRDD.map(exam => LabeledPoint(exam.x, Vectors.dense(exam.y))
antwoordde op 04/05/2017 om 04:59
bron van user

stemmen
1

Ik had dit probleem omdat mijn naam van de variabele werd genomen door een functie.

Zo private val Seq(transaction, transaction2) = insertTx(...

werd

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

met transactiecode wordt de dader.

antwoordde op 09/08/2017 om 20:15
bron van user

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