pyspark.streaming.StreamingContext.transform

StreamingContext。 變換 ( dstreams:列表(DStream(任何]],transformFunc:可調用的[[…],pyspark.rdd.RDD [T]] )→pyspark.streaming.dstream.DStream(T]

創建一個新的DStream中每個抽樣是通過應用一個函數生成DStreams的抽樣。JavaRDDs在變換函數參數的順序將相應的順序一樣DStreams在列表中。

以前的

pyspark.streaming.StreamingContext.stop

下一個

pyspark.streaming.StreamingContext.union