Re: how to convert JavaDStream to JavaRDD

[Laeeq Ahmed]

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 
<mrajaf...@gmail.com> wrote:
 


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<String> lines_2 = 
ssc.textFileStream("hdfs://localhost:9000/user/rajesh/EventsDirectory/");

How to convert JavaDStream<String> result to JavaRDD<String>? 
if we can convert. I can use collect() method on JavaRDD and process my 
textfile.

I'm not able to find collect method on JavaRDD<String>.

Thank you very much in advance.

Regards,
Rajesh