Spark Streaming-Receiver啓動和數據接收

養成一個記筆記的習慣！！！緩存 小案例：網絡 def fromsocket(ssc: StreamingContext): Unit ={ /**使用updateStateByKey前必需要設置checkpoint*/ ssc.checkpoint("hdfs://zhumaster:8020/data/checkpoint") /** 如使用socket網絡嵌套字做爲輸入模式，使用命

>>阅读原文<<