pyspark.streaming.DStream.foreachRDD

DStream.foreachRDD(func)[source]

Apply a function to each RDD in this DStream.