pyspark.streaming.DStream.foreachRDD

DStream.foreachRDD(func: Union[Callable[[pyspark.rdd.RDD[T]], None], Callable[[datetime.datetime, pyspark.rdd.RDD[T]], None]]) → None

Apply a function to each RDD in this DStream.

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