pyspark.streaming.StreamingContext.transform# StreamingContext.transform(dstreams, transformFunc)[source]# 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.