pyspark.streaming.DStream.filter

DStream。 过滤器 ( f:可调用的((T],bool] )→pyspark.streaming.dstream.DStream(T]

返回一个新的DStream只包含的元素满足谓词。

以前的

pyspark.streaming.DStream.countByWindow

下一个

pyspark.streaming.DStream.flatMap