Hello list, for the code in the link: https://github.com/apache/spark/blob/v3.2.1/examples/src/main/scala/org/apache/spark/examples/streaming/SqlNetworkWordCount.scala
I am not sure, why enclose the RDD to Dataframe logic in a foreachRDD block? What's the use of foreachRDD? Thanks in advance.