pyspark.streaming.DStream.map

DStream.map(f, preservesPartitioning=False)

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

pyspark.streaming.DStream.leftOuterJoin pyspark.streaming.DStream.mapPartitions