Hi, I implemented the streamingKmeans example provided in the spark website but in Java. The full implementation is here,
http://pastebin.com/CJQfWNvk But i am not getting anything in the output except occasional timestamps like one below: ------------------------------------------- Time: 1466176935000 ms ------------------------------------------- Also, i have 2 directories: "D:\spark\streaming example\Data Sets\training" "D:\spark\streaming example\Data Sets\test" and inside these directories i have 1 file each "samplegpsdata_train.txt" and "samplegpsdata_test.txt" with training data having 500 datapoints and test data with 60 datapoints. I am very new to the spark systems and any help is highly appreciated. Thanks & Regards Biplob Biswas
