在前面的例子中，每次輸入的單詞在被記錄以后，就會(huì)被刪除，如果我們要保持之前的數(shù)據(jù)，隨著相同字母的輸入，能夠?qū)崿F(xiàn)累計(jì)更新呢？
我們就需要用到updatestatebykey操作了。
當(dāng)我們要實(shí)現(xiàn)有狀態(tài)的transformation時(shí)需要開啟檢查點(diǎn)：

開啟我們的10008端口：

輸入單詞：

在終端輸出如下：


可見實(shí)現(xiàn)了累加的效果。
觀看檢查點(diǎn)位置：

與50位技術(shù)專家面對(duì)面20年技術(shù)見證，附贈(zèng)技術(shù)全景圖

總結(jié)

以上是生活随笔為你收集整理的sparkstreaming（2）——updatestatebykey的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。