pyspark.streaming.DStream.mapPartitionsWithIndex

DStream.mapPartitionsWithIndex(f, preservesPartitioning=False)

Return a new DStream in which each RDD is generated by applying mapPartitionsWithIndex() to each RDDs of this DStream.

pyspark.streaming.DStream.mapPartitions pyspark.streaming.DStream.mapValues