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

開啟我們的10008端口：

輸入單詞：

在終端輸出如下：


可見實現了累加的效果。
觀看檢查點位置：

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

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。