pyspark.streaming.DStream.count

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

返回一个新的DStream每个抽样有单个元素通过计算每个抽样生成DStream。

以前的

pyspark.streaming.DStream.context

下一个

pyspark.streaming.DStream.countByValue