pyspark.streaming.DStream.combineByKey

DStream.combineByKey(createCombiner, mergeValue, mergeCombiners, numPartitions=None)

Return a new DStream by applying combineByKey to each RDD.

pyspark.streaming.DStream.cogroup pyspark.streaming.DStream.context