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.

previous

pyspark.streaming.DStream.leftOuterJoin

next

pyspark.streaming.DStream.mapPartitions