Spark學習之15：Spark Streaming執行流程(1)

本文以spark streaming文檔中建立Socket Stream的例子來描述StreamingContext的執行流程。 例子示例代碼： val lines = ssc.socketTextStream("localhost", 9999) val words = lines.flatMap(_.split(" ")) val pairs = words.map(word => (word

>>阅读原文<<