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

開啟我們的10008端口：

輸入單詞：

在終端輸出如下：


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

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

總結(jié)

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

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