uj5u.com熱心網友回復:
import org.apache.spark.mllib.linalg.Vectors
import org.apache.spark.mllib.linalg.distributed.RowMatrix
val rawRdd = spark.sparkContext.parallelize(Array("12,32","125,125","13,35"))
val vectors = rawRdd.map(_.split(",")).map(_.toArray[Double]).map(g => Vectors.dense(g))
val rm = new RowMatrix(vectors)
scala 2.11.12
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/12502.html
標籤:Spark
