pyspark.streaming.DStream.combineByKey

DStream.combineByKey(createCombiner: Callable[[V], U], mergeValue: Callable[[U, V], U], mergeCombiners: Callable[[U, U], U], numPartitions: Optional[int] = None) → pyspark.streaming.dstream.DStream[Tuple[K, U]]

Return a new DStream by applying combineByKey to each RDD.

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