失眠网,内容丰富有趣,生活中的好帮手!
失眠网 > 95-910-142-源码-FlinkSQL-FlinkSQL追加模式与缩进模式区别

95-910-142-源码-FlinkSQL-FlinkSQL追加模式与缩进模式区别

时间:2018-08-26 23:39:52

相关推荐

95-910-142-源码-FlinkSQL-FlinkSQL追加模式与缩进模式区别

文章目录

1.世界2.**将表转换为DataStream**3.案例

1.世界

2.将表转换为DataStream

一个Table是流媒体查询的结果将动态更新,即它正在改变,因为新记录的查询的输入流到达。因此,DataStream转换这种动态查询需要对表的更新进行编码。

将一个Table转换为一个DataStream有两种模式:

追加模式:只有在动态Table仅通过INSERT更改修改时才能使用此模式,即它仅附加并且以前发出的结果永远不会更新缩进模式:始终可以使用此模式。它用标志编码INSERT和DELETE改变boolean。始终可以使用此模式。返回值是boolean类型。它用true或false来标记数据的插入和撤回,返回true代表数据插入,false代表数据的撤回</

如果觉得《95-910-142-源码-FlinkSQL-FlinkSQL追加模式与缩进模式区别》对你有帮助,请点赞、收藏,并留下你的观点哦!

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。