I think I got it parsedData.foreach( new VoidFunction<Vector>() { @Override public void call(Vector vector) throws Exception { System.out.println(clusters.predict(vector));
} } ); On Mon, Oct 17, 2016 at 10:56 AM, Reth RM <reth.ik...@gmail.com> wrote: > Could you please point me to sample code to retrieve the cluster members > of K mean? > > The below code prints cluster centers. * I > needed cluster members belonging to each center.* > > > > val clusters = KMeans.train(parsedData, numClusters, numIterations) > clusters.clusterCenters.foreach(println) > >