pyspark.streaming.DStream.union — PySpark In-Progress documentation
-
DStream.union(other)[source]#
Return a new DStream by unifying data of another DStream with this DStream.
- Parameters
- other
DStream Another DStream having the same interval (i.e., slideDuration)
as this DStream.