pyspark.streaming.DStream.map# DStream.map(f, preservesPartitioning=False)[source]# Return a new DStream by applying a function to each element of DStream.