Re: Implement Count by Minute in Spark Streaming

[Tobias Pfeiffer]

>
>   myRdd.countByWindow(Seconds(1), Seconds(1))
>

Of course it would be myDStream.countByWindow(Seconds(1), Seconds(1))