pyspark.streaming.DStream.map

DStream.map(f: Callable[[T], U], preservesPartitioning: bool = False) → pyspark.streaming.dstream.DStream[U]

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

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