pyspark.streaming.DStream.countByWindow

DStream。 countByWindow ( windowDuration:int,slideDuration:int )→pyspark.streaming.dstream.DStream(int]

返回一個新的DStream每個抽樣生成單個元素通過計算元素的數量在一個窗口DStream。windowDuration和slideDuration中定義的窗口()操作。

這相當於窗口(windowDuration slideDuration) .count(),但如果窗戶很大將更有效。

以前的

pyspark.streaming.DStream.countByValueAndWindow

下一個

pyspark.streaming.DStream.filter