pyspark.streaming.DStream.mapValues

DStream.mapValues(f: Callable[[V], U]) → pyspark.streaming.dstream.DStream[Tuple[K, U]]

Return a new DStream by applying a map function to the value of each key-value pairs in this DStream without changing the key.

pyspark.streaming.DStream.mapPartitionsWithIndex pyspark.streaming.DStream.partitionBy