Try doing DStream.foreachRDD and then printing the RDD count and further inspecting the RDD. On Jul 13, 2014 1:03 AM, "Walrus theCat" <walrusthe...@gmail.com> wrote:
> Hi,
>
> I have a DStream that works just fine when I say:
>
> dstream.print
>
> If I say:
>
> dstream.map(_,1).print
>
> that works, too. However, if I do the following:
>
> dstream.reduce{case(x,y) => x}.print
>
> I don't get anything on my console. What's going on?
>
> Thanks
>
