我想用我自己的平均值和sigma创建一个rdd[vector],我已经做了:
val mean = Random.nextInt(100)
val sigma = 2
val data: RDD[Vector] = RandomRDDs.normalVectorRDD(sc, numRows = 180, numCols = 20).map(v => mean + sigma * v)
但我有以下错误:
overloaded method value * with alternatives:
(x: Double)Double <and>
(x: Float)Float <and>
(x: Long)Long <and>
(x: Int)Int <and>
(x: Char)Int <and>
(x: Short)Int <and>
(x: Byte)Int
cannot be applied to (org.apache.spark.mllib.linalg.Vector)
val data: RDD[Vector] = RandomRDDs.normalVectorRDD(sc, numRows = 180, numCols = 20).map(v => mean + sigma * v)
我不理解这个错误,因为在scala文档中,他们也做了randomrdds.normal(sc,n,p,seed).map(lambda v:mean+sigma*v)
谢谢
1条答案
按热度按时间uqzxnwby1#
spark医生。引用.normal()方法:
实际上运行正常。
如果需要对向量应用变换: