pyspark.streaming.StreamingContext.union

StreamingContext。 聯盟 ( *dstreams:pyspark.streaming.dstream.DStream(T] )→pyspark.streaming.dstream.DStream(T]

創建一個統一的從多個相同類型的DStreams DStream和滑動時間相同。

以前的

pyspark.streaming.StreamingContext.transform

下一個

pyspark.streaming.StreamingContext.binaryRecordsStream