pyspark.streaming.DStream.map

DStream.map(f, preservesPartitioning=False)[source]

Return a new DStream by applying a function to each element of DStream.