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.