pyspark.streaming.DStream.union

DStream.union(other: pyspark.streaming.dstream.DStream[U]) → pyspark.streaming.dstream.DStream[Union[T, U]]

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