Spark Streaming實戰之黑名單過濾

1.需求場景 訪問日誌： 201801,zs 201802,ls 201803,ww ..... 黑名單： zs,ls... 現在需要把黑名單中的人從訪問日誌中給過濾掉，然後得到一份新的訪問日誌 2.思路分析 要實現上邊的需求，首先要進行思路分析，即如何實現 我們可以把黑名單數據先變成一個RDD，將它變成(zs,true) (ls,true)這樣的形式，然後再將訪問日誌變成(zs,<201801,

>>阅读原文<<