在前面的例子中，每次输入的单词在被记录以后，就会被删除，如果我们要保持之前的数据，随着相同字母的输入，能够实现累计更新呢？ 我们就需要用到updatestatebykey操作了。 当我们要实现有状态的transformation时需要开启检查点：
开启我们的10008端口：
输入单词：
在终端输出如下：
可见实现了累加的效果。 观看检查点位置：
sparkstreaming（2）——updatestatebykey
2020-11-11 17:06:09
浏览数 (2)
在前面的例子中，每次输入的单词在被记录以后，就会被删除，如果我们要保持之前的数据，随着相同字母的输入，能够实现累计更新呢？ 我们就需要用到updatestatebykey操作了。 当我们要实现有状态的transformation时需要开启检查点：
开启我们的10008端口：
输入单词：
在终端输出如下：
可见实现了累加的效果。 观看检查点位置：
下载App
关注公众号