How apply machine learning on spark streaming data in real time



Dear Sir / Madam,

Is there a way to apply machine learning algorithms to on spark streaming data in real time.

I am already using Spark MLlib, but I am not sure how to apply the algorithm on the streamed data.

I have tried a few examples online but nothing seems to work for K-Means / Streaming K-Means

I want to apply the algorithm in real time, not loading form any text files.

Thank You


I would suggest you post your entire code here so people can give you better suggestion.