开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

社区首页 >专栏 >sparkstreaming（2）——updatestatebykey

sparkstreaming（2）——updatestatebykey

gzq大数据

发布于 2020-11-11 17:06:09

3580

发布于 2020-11-11 17:06:09

举报

文章被收录于专栏：大数据那些事

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

开启我们的10008端口：

输入单词：

在终端输出如下：

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

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2020/10/17 ，如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

评论

登录后参与评论

0 条评论

热度

最新

LV.