pyspark.streaming.DStream.filter

DStream。 過濾器 ( f:可調用的((T],bool] )→pyspark.streaming.dstream.DStream(T]

返回一個新的DStream隻包含的元素滿足謂詞。

以前的

pyspark.streaming.DStream.countByWindow

下一個

pyspark.streaming.DStream.flatMap