pyspark.streaming.StreamingContext.union#

StreamingContext.union(*dstreams)[source]#

Create a unified DStream from multiple DStreams of the same type and same slide duration.