我对spark很有经验。然而，我第一次学习Spark流，发现它很难理解。很难理解应用程序的流程。例如，以下网站上给出的示例
http://ampcamp.berkeley.edu/3/exercises/realtime-processing-with-spark-streaming.html
第3部分的代码。进一步练习，我们有

val words = statuses.flatMap(status => status.split(" "))
val hashtags = words.filter(word => word.startsWith("#"))
val counts = hashtags.map(tag => (tag, 1))
                         .reduceByKeyAndWindow(_ + _, _ - _, Seconds(60 * 5), Seconds(1))

据推测，它计算的是过去5分钟最流行的twitter散列标签。那么，这是怎么回事。是否有某种隐藏循环每5分钟执行一次？价值是多少 words 以及 hashtags ，每秒钟还是5分钟？这是怎么回事？我迷路了，请帮帮我。