大數據之實時項目 第6天 利用redis進行去重

上篇：大數據之實時項目–第5天 （kafka消費）java 一、代碼編寫 （1）利用redis進行去重過濾基本代碼實現web //利用redis進行去重過濾 val filteredDstream: DStream[Startuplog] = startuplogStream.transform { rdd => println("過濾前:"+rdd.count()

>>阅读原文<<