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

>>阅读原文<<