FlinkSQL中的Retraction回退更新是怎么进行的
发表于:2024-10-23 作者:千家信息网编辑
千家信息网最后更新 2024年10月23日,FlinkSQL中的Retraction回退更新是怎么进行的,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。前言如果你在使用FlinkSQ
千家信息网最后更新 2024年10月23日FlinkSQL中的Retraction回退更新是怎么进行的
FlinkSQL中的Retraction回退更新是怎么进行的,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。
前言
如果你在使用FlinkSQL时出现如下的报错:
Table is not an append-only table. Use the toRetractStream() in order to handle add and retract messages.那么你就有必要了解一下Flink中的 回退更新。
简介
通俗的讲"回退更新"就是传统数据里面的更新操作,也就是说Retract是流式计算场景下对数据更新的处理。
使用flinkSQL处理实时数据当我们把表转化成流的时候,需要用toAppendStream与toRetractStream这两个方法。稍不注意可能直接选择了toAppendStream。
区别
追加模式:只有在动态Table
仅通过INSERT
更改修改时才能使用此模式,即它仅附加,并且以前发出的结果永远不会更新。
如果更新或删除操作使用追加模式会失败报错。
缩进模式: 始终可以使用此模式。返回值是boolean类型。它用true或false来标记数据的插入和撤回,返回true代表数据插入,false代表数据的撤回。
按照官网的理解如果数据只是不断添加,可以使用追加模式,其余方式则不可以使用追加模式,而缩进模式侧可以适用于更新,删除等场景。具体的区别如下图所示:
通过上图可以清晰的看到两种方式的区别,当我们使用的sql语句包含:count() group by时,必须使用缩进模式。
举个例子
上面的例子输出结果如下:
前面数字相同的是同一组操作,true代表的是写入,false代表的是撤回。
看完上述内容,你们掌握FlinkSQL中的Retraction回退更新是怎么进行的的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注行业资讯频道,感谢各位的阅读!
更新
模式
数据
代表
方法
例子
内容
场景
方式
更多
结果
问题
处理
相同
通俗
必要
束手无策
为此
上图
不断
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
网络技术用英语怎么写
数据库无法验证被锁定
玉溪农业职业技术学院网络技术
关于网络安全的责任书
做软件开发怎么赚钱
数据库ping通
济南超算中心服务器租用
服务器管理入门书籍推荐
电大数据库应用课程实训报告
mysql写入数据库
网络安全加强一体化考核
网络安全中心图片
网络打印服务器怎么连接笔记本
应急管理月答题服务器慢
秦皇岛软件开发工程师
软件开发实验选题
devcc连接数据库
玄奥周易软件开发
旧机箱改造数据库
为什么软件开发网页设计是青春饭
服务器安全狗好用么
浙江省软件开发服务
不让登录密码不存入数据库
人工神经网络技术实现
邹平设备软件开发定制
远程控制服务器搭建软件
安卓连接服务器访问数据库
.ibd文件导入到数据库
mysql数据库初始化教程
前瞻数据库下载