Spark Streaming Akkumulierte Wortzahl

Dies ist ein in Scala geschriebenes Spark-Streaming-Programm. Es zählt die Anzahl der Wörter von einem Socket in jeder Sekunde. Das Ergebnis wäre die Wortanzahl, zum Beispiel die Wortanzahl von 0 bis 1 und die Wortanzahl dann von 1 bis 2. Aber ...