SparkStreaming——實例3：帶狀態操作

帶狀態操作，updateStateByKey 實例1、實例2只是把這5s中產生的數據wordcount，也就是每5s統計一次這5s的數據， 而如果我們需要統計從一開始到現在產生的數據，就需要updateStateByKey   updateStateByKey操作，可以讓我們爲每個key維護一份state，並持續不斷的更新該state。 1、首先，要定義一個state，可以是任意的數據類型； 2、

>>阅读原文<<