Predicting Against Test Data

Import

import org.apache.spark.rdd.RDD

Code

val predictions:RDD[Double]=model.predict(scaledTestSet.map(point=>point.features))

Print RDD

// print five 
predictions.take(5).foreach(println)

// print all
predictions.map(p => "prediction: "+p).collect().foreach(println)