pyspark.streaming.DStream.count

DStream.count() → pyspark.streaming.dstream.DStream[int][source]

Return a new DStream in which each RDD has a single element generated by counting each RDD of this DStream.

previous

pyspark.streaming.DStream.context

next

pyspark.streaming.DStream.countByValue