spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Biplob Biswas <revolutioni...@gmail.com>
Subject Running JavaBased Implementation of StreamingKmeans
Date Sat, 18 Jun 2016 17:30:52 GMT
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

Mime
View raw message