the following question is similar: Spark Streaming with Twitter - No output streams registered, so nothing to execute however I think that in line 51
using wordCounts.print()
I actually do output some results.
Basic Code:
ssc.start()
ssc.awaitTermination()
val lines = messages.map(_._2)
val words = lines.flatMap(_.split(" "))
val wordCounts = words.map(x => (x, 1L)).reduceByKey(_ + _)
wordCounts.print()
Or do I misunderstand something here? To follow along: https://github.com/dataplayground/playground/blob/master/app/actors/DirectStreamingActor.scala