pyspark.streaming.DStream.foreachRDD#

DStream.foreachRDD(func)[source]#

Apply a function to each RDD in this DStream.