pyspark.streaming.DStream.transform

DStream。 變換 ( 函數:聯盟(可調用的((pyspark.rdd.RDD(T]],pyspark.rdd.RDD(U]],可調用的((datetime.datetime,pyspark.rdd.RDD(T]],pyspark.rdd.RDD(U]]] )→pyspark.streaming.dstream.TransformedDStream(U]

返回一個新的DStream每個抽樣生成通過應用一個函數在每個抽樣DStream。

函數可以有一個論點的抽樣,或者有兩個參數(時間,抽樣)

以前的

pyspark.streaming.DStream.slice

下一個

pyspark.streaming.DStream.transformWith