Re: how to send JavaDStream RDD using foreachRDD using Java

Tue, 03 Feb 2015 07:58:00 -0800 

Hi all,
issue has bee resolved,
when I used 
rdd.foreachRDD(new Function<JavaRDD&lt;String>, Void>() {
                @Override
                public Void call(JavaRDD<String> rdd) throws Exception {
                        if(rdd!=null)
                        {       
                                List<String> result = rdd.collect();
                                KafkaUtil.sendString(p,topic,result.get(0));
 KafkaUtils.sendDataAsString(MTP,topicName, result.get(0)); 
                                
                        }



--
View this message in context: 
http://apache-spark-user-list.1001560.n3.nabble.com/how-to-send-JavaDStream-RDD-using-foreachRDD-using-Java-tp21456p21483.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to