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)