Spark:没有注册输出操作,因此无需执行任何操作

Question

下面的问题是类似的:使用Twitter的Spark Streaming - 没有注册输出流,所以没有什么可以执行,但我认为在线51使用wordCounts.print()我实际上输出了一些结果.

基本代码:

ssc.start()
      ssc.awaitTermination()
      val lines = messages.map(_._2)
      val words = lines.flatMap(_.split(" "))
      val wordCounts = words.map(x => (x, 1L)).reduceByKey(_ + _)
      wordCounts.print()

或者我在这里误解了什么？要跟进:https: //github.com/dataplayground/playground/blob/master/app/actors/DirectStreamingActor.scala

Answer 1

ssc.start()
ssc.awaitTermination()

应该是你的代码中的最后一个.