pyspark.streaming.DStream.union

DStream.union(other)

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.

pyspark.streaming.DStream.transformWith pyspark.streaming.DStream.updateStateByKey