It will run distributed
On Mar 2, 2016 3:00 PM, "Priya Ch" wrote:
> Hi All,
>
> I am running k-means clustering algorithm. Now, when I am running the
> algorithm as -
>
> val conf = new SparkConf
> val sc = new SparkContext(conf)
> .
> .
> val kmeans = new
Hi All,
I am running k-means clustering algorithm. Now, when I am running the
algorithm as -
val conf = new SparkConf
val sc = new SparkContext(conf)
.
.
val kmeans = new KMeans()
val model = kmeans.run(RDD[Vector])
.
.
.
The 'kmeans' object gets created on driver. Now does *kmeans.run() *get