dstream.foreachRDD(_.collect.foreach(println)) On Wed, Jul 6, 2016 at 1:19 PM, Rabin Banerjee <dev.rabin.baner...@gmail.com> wrote: > Collect will help then . May be something like this, > foreachRDD( rdd => { for(item <- rdd.collect().toArray) { println(item); } > }) >
--------------------------------------------------------------------- To unsubscribe e-mail: user-unsubscr...@spark.apache.org