当前位置: 首页 > article >正文

6 Flink Table 和相关概念

1. 动态表

动态表是为了在无界流中实现类似关系型数据库的语义而存在的,动态表把流分为插入流更新日志流 的形式来持续更新表里的数据并展示出来

1.1 动态表的更新与追加

如下图所示一张动态表通过user字段分组聚合统计url的点击次数,左侧是输入的数据,对应右侧输出的数据。
在这里插入图片描述

1.2 动态表到流的转换

最终输出的都是以流的方式把数据输出出来,在动态表中的数据转成流的方式输出时,有三种形式

  • Append-only: 只输出Insert方式的流数据,可以通过指定ChangelogMode.insertOnly()来实现

  • Retrat: 它接受数据的插入,更新前,更新后,删除所有操作,它把insert编码为add message,delete编码为 retract massage,update编码为retract message和add message的组合操作,可以通过指定ChangelogMode.all()来实现**(它是默认的输出方式)**
    在这里插入图片描述

  • Upsert: 它也会接受所有的操作,它把insert和update操作编码为upsert message,delete操作编码为delete message,它与Retract流的区别在于update操作的时直接基于key更新,只需单个消息编码,因此更加的高效
    在这里插入图片描述


http://www.kler.cn/a/546858.html

相关文章:

  • android 的抓包工具
  • 使用 Python 爬虫获取微店快递费用 item_fee API 接口数据
  • 光谱相机在天文学领域的应用
  • docker学习---第3步:docker实操大模型
  • Windows 图形显示驱动开发-WDDM 2.0 -GPU虚拟寻址概述
  • Elasticsearch+Logstash+Kibana可视化集群部署
  • 如何提升插屏广告在游戏APP广告变现表现,增加变现收益
  • 团结引擎 OpenHarmony 平台全面支持 UAAL,实现引擎能力嵌入原生应用
  • STM32:迎接汽车与AI时代MCU新挑战
  • jenkins war Windows安装
  • ArcGISPro 新建shp+数据结构
  • 【Qt】Qt的对象树结构
  • Unity UI个人总结
  • untiy3D 让角色动起来,角色动画的使用
  • 【Java基础-44.8】Java中Map集合的遍历方式详解
  • Golang GORM系列:GORM事务及错误处理
  • 21爬虫:使用playwright接管本地已经登录淘宝的浏览器并查找python相关店铺信息
  • MaxKB本地部署celery_default is stopped
  • Node.js技术原理分析系列——Node.js调试能力分析
  • vue2 生命周期