pyspark.streaming.DStream.groupByKey

DStream.groupByKey(numPartitions=None)

Return a new DStream by applying groupByKey on each RDD.

pyspark.streaming.DStream.glom pyspark.streaming.DStream.groupByKeyAndWindow