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