3
我是Spark的新手。我能够训练DataSet。但不能使用训练的数据集进行预测。Spark:如何使用训练好的数据集进行预测(MLLIB:SVMWithSGD)
这里是训练数据的代码是1800x4000矩阵。
import org.apache.spark.mllib.classification.SVMWithSGD
import org.apache.spark.mllib.regression.LinearRegressionWithSGD
import org.apache.spark.mllib.regression.LabeledPoint
import org.apache.spark.mllib.linalg.Vectors
// Load and parse the data
val data = sc.textFile("data/mllib/ridge-data/myfile.txt")
val parsedData = data.map { line =>
val parts = line.split(' ')
LabeledPoint(parts(0).toDouble, Vectors.dense(parts(1).split(' ').map(_.toDouble)))
}
val firstDataPoint = parsedData.take(1)(0)
// Building the model
val numIterations = 100
val model = SVMWithSGD.train(parsedData, numIterations)
//val model = LinearRegressionWithSGD.train(parsedData,numIterations)
val labelAndPreds = parsedData.map { point =>
val prediction = model.predict(point.features)
(point.label, prediction)
}
val trainErr = labelAndPreds.filter(r => r._1 != r._2).count.toDouble/parsedData.count
println("Training Error = " + trainErr)
现在我加载要使用的数据,以执行预测:数据是1800个值
val test = sc.textFile("data/mllib/ridge-data/data.txt")
但不知道如何使用该数据来执行预测的矢量。请帮忙。