Hi,
First use foreachrdd and then use collect as
DStream.foreachRDD(rdd => {
rdd.collect.foreach({
Also its better to use scala. Less verbose.
Regards,
Laeeq
On Wednesday, July 9, 2014 3:29 PM, Madabhattula Rajesh Kumar
wrote:
Hi Team,
Could you please help me to resolve bel
Hi Team,
Could you please help me to resolve below query.
My use case is :
I'm using JavaStreamingContext to read text files from Hadoop - HDFS
directory
JavaDStream lines_2 =
ssc.textFileStream("hdfs://localhost:9000/user/rajesh/EventsDirectory/");
How to convert JavaDStream result to JavaRDD
