pyspark.streaming.DStream.transform =================================== .. currentmodule:: pyspark.streaming .. automethod:: DStream.transform