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
