sparkstreaming（2）——updatestatebykey

在前面的例子中，每次輸入的單詞在被記錄以後，就會被刪除，如果我們要保持之前的數據，隨着相同字母的輸入，能夠實現累計更新呢？ 我們就需要用到updatestatebykey操作了。 當我們要實現有狀態的transformation時需要開啓檢查點： 開啓我們的10008端口： 輸入單詞： 在終端輸出如下： 可見實現了累加的效果。 觀看檢查點位置：

>>阅读原文<<