pyspark.streaming.DStream.count# DStream.count()[source]# Return a new DStream in which each RDD has a single element generated by counting each RDD of this DStream.