pyspark.streaming.DStream.union

DStream。 聯盟 ( 其他:pyspark.streaming.dstream.DStream(U] )→pyspark.streaming.dstream.DStream(聯盟(T,U] ]

返回一個新的DStream統一數據的另一個DStream DStream。

參數

其他 DStream

另一個DStream擁有相同的時間間隔(即。,這個DStream slideDuration)。

以前的

pyspark.streaming.DStream.transformWith

下一個

pyspark.streaming.DStream.updateStateByKey