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
