pyspark.streaming.DStream.combineByKey

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

Return a new DStream by applying combineByKey to each RDD.