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.

pyspark.streaming.DStream.context pyspark.streaming.DStream.countByValue