20 lines
338 B
Scala
20 lines
338 B
Scala
package ClusterSOData
|
|
|
|
import org.apache.spark.SparkContext
|
|
import org.apache.spark.SparkContext._
|
|
import org.apache.spark._
|
|
import org.apache.spark.sql._
|
|
|
|
object KMeans {
|
|
/**
|
|
* Run KMeans clustering on an input RDD vector
|
|
*/
|
|
def train(
|
|
//data: DataSet
|
|
)
|
|
{
|
|
//Normalise data using Euclidean normalisation
|
|
|
|
}
|
|
}
|