spark代码问题

是 否 +2 论坛币

k人 参与回答

经管之家送您一份

应届毕业生专属福利!

求职就业群

赵安豆老师微信：zhaoandou666

经管之家联合CDA

送您一个全额奖学金名额~ !

立即领取

感谢您参与论坛问题回答

经管之家送您两个论坛币！

+2 论坛币

今日测试一段代码如下：

val data = rawData.map { line =>

     |       val values = line.split(',').map(_.toDouble)

     |       val featureVector = Vectors.dense(values.init)

     |       val label = values.last - 1

     |       LabeledPoint(label, featureVector)

     |     }

整体运行没有错误，当然前提是import了相应的包，但是本人算是折腾帝，尝试着将代码分开写，分开运行，在建立稠密向量时，报错，显示如下：

val n2=Vectors.dense(n1.init)

<console>:34: error: value init is not a member of org.apache.spark.rdd.RDD[Array[Double]]

       val n2=Vectors.dense(n1.init)

提示没有init操作，因为是小白，所以百思不得其解这个问题，还望坛子里的高手能够解答一二，不胜感激！

扫码加我 拉你入群

请注明：姓名-公司-职位

以便审核进群资格，未注明则拒绝

分享0 收藏0 回帖

关键词：Spark Park SPAR SPA vectors

还望高手赐教，小白实在没搞懂为啥不能分开写这段代码！

没有搞Scala的么！