pyspark.streaming.DStream.transformWith¶
-
DStream。transformWith( 函數:聯盟(可調用的((pyspark.rdd.RDD(T],pyspark.rdd.RDD(U]],pyspark.rdd.RDD(V]],可調用的((datetime.datetime,pyspark.rdd.RDD(T],pyspark.rdd.RDD(U]],pyspark.rdd.RDD(V]]],其他:pyspark.streaming.dstream.DStream(U],keepSerializer:bool=假 )→pyspark.streaming.dstream.DStream(V] ¶ -
返回一個新的DStream每個抽樣生成通過應用一個函數在每個抽樣DStream和DStream“其他”。
函數可以有兩個參數(rdd_a,rdd_b)或有三個參數(時間,rdd_a,rdd_b)