pyspark.streaming.DStream.combineByKey#

DStream.combineByKey(createCombiner, mergeValue, mergeCombiners, numPartitions=None)[source]#: Return a new DStream by applying combineByKey to each RDD.