Spark Streaming-Receiver启动和数据接收

养成一个记笔记的习惯！！！缓存 小案例：网络 def fromsocket(ssc: StreamingContext): Unit ={ /**使用updateStateByKey前必需要设置checkpoint*/ ssc.checkpoint("hdfs://zhumaster:8020/data/checkpoint") /** 如使用socket网络嵌套字做为输入模式，使用命

>>阅读原文<<