pyspark.streaming.DStream.union#

DStream.union(other)[source]#

Return a new DStream by unifying data of another DStream with this DStream.

Parameters

otherDStream: Another DStream having the same interval (i.e., slideDuration) as this DStream.