A KMeansModel was trained in the previous step, and it was saved to "modelFile" as a Java object file. This step is loading the model back and reconstructing the KMeansModel, which can then be used to classify new tweets into different clusters. Joseph
On Thu, May 7, 2015 at 12:40 PM, anshu shukla <anshushuk...@gmail.com> wrote: > Can anyone please explain - > > println("Initalizaing the the KMeans model...") > val model = new > KMeansModel(ssc.sparkContext.objectFile[Vector](modelFile.toString).collect()) > > where modelfile is *directory to persist the model while training * > > > REF- > > > https://github.com/databricks/reference-apps/blob/master/twitter_classifier/predict.md > > > -- > Thanks & Regards, > Anshu Shukla >