pyspark.streaming.DStream.foreachRDD

DStream.foreachRDD(func)

Apply a function to each RDD in this DStream.

pyspark.streaming.DStream.flatMapValues pyspark.streaming.DStream.fullOuterJoin