pyspark.streaming.StreamingContext.union

StreamingContext.union(*dstreams)

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

pyspark.streaming.StreamingContext.transform pyspark.streaming.StreamingContext.binaryRecordsStream