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.