sparkstreaming（2）——updatestatebykey

在前面的例子中，每次输入的单词在被记录以后，就会被删除，如果我们要保持之前的数据，随着相同字母的输入，能够实现累计更新呢？ 我们就需要用到updatestatebykey操作了。 当我们要实现有状态的transformation时需要开启检查点：

开启我们的10008端口：

输入单词：

在终端输出如下：

可见实现了累加的效果。 观看检查点位置：