pyspark.streaming.DStream.union

DStream.union(other: pyspark.streaming.dstream.DStream[U]) → pyspark.streaming.dstream.DStream[Union[T, U]][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.

previous

pyspark.streaming.DStream.transformWith

next

pyspark.streaming.DStream.updateStateByKey