pyspark.streaming.StreamingContext.union

StreamingContext.union(*dstreams: pyspark.streaming.dstream.DStream[T]) → pyspark.streaming.dstream.DStream[T][source]

Create a unified DStream from multiple DStreams of the same type and same slide duration.

previous

pyspark.streaming.StreamingContext.transform

next

pyspark.streaming.StreamingContext.binaryRecordsStream