Spark.
r_rdd.take(100) val r_rdd2= sc.parallelize(r_rdd1) This section of the code separates the data into the vector and label(class/predicted) section. The data has to be converted into label points where the label is the predicted array based on the given data and the vector is the other section of the