DStream.
combineByKey
Return a new DStream by applying combineByKey to each RDD.
previous
pyspark.streaming.DStream.cogroup
next
pyspark.streaming.DStream.context