Convert DStream[Long] to Long

[Sergio Jiménez Barrio]

Hi,

I need compare the count of messages recived if is 0 or not, but
messages.count() return a DStream[Long]. I tried this solution:

val cuenta  = messages.count().foreachRDD{ rdd =>
                                                rdd.first()
                                             }

But this return a type Unit, not Long.


Any suggestion? Thanks!