spark streaming 廣播變量的測試

最近寫的一個流式的程序須要從redis 中獲取變量信息，並廣播，其中redis裏面的信息是變更的，要求廣播變量也要跟着改變，下面是測試代碼：redis val dStream = KafkaUtils.createDirectStream[String, String]( ssc, PreferConsistent, Subscribe[String, String]

>>阅读原文<<