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