pyspark.streaming.StreamingContext.transform

StreamingContext.transform(dstreams, transformFunc)

Create a new DStream in which each RDD is generated by applying a function on RDDs of the DStreams. The order of the JavaRDDs in the transform function parameter will be the same as the order of corresponding DStreams in the list.

pyspark.streaming.StreamingContext.stop pyspark.streaming.StreamingContext.union