Usually while processing a DStream one uses foreachRDD. foreachRDD gives you to deal with an RDD which has a method isEmpty that you can use.
..Manas -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/how-to-judge-a-DStream-is-empty-or-not-after-filter-operation-so-that-return-a-boolean-reault-tp25553p25583.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
