pyspark.streaming.DStream.count

DStream。 數 ( )→pyspark.streaming.dstream.DStream(int]

返回一個新的DStream每個抽樣有單個元素通過計算每個抽樣生成DStream。

以前的

pyspark.streaming.DStream.context

下一個

pyspark.streaming.DStream.countByValue