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

10、Flink 动态表之动态表 连续查询(Continuous Query)详解

b)动态表 & 连续查询(Continuous Query)

动态表 是 Flink 的支持流数据的 Table API 和 SQL 的核心概念;与表示批处理数据的静态表不同,动态表是随时间变化的,可以像查询静态批处理表一样查询它们。

查询动态表将生成一个 连续查询 ,一个连续查询永远不会终止,结果会生成一个动态表;查询不断更新其(动态)结果表,以反映其(动态)输入表上的更改;本质上,动态表上的连续查询非常类似于定义物化视图的查询

需要注意的是,连续查询的结果在语义上总是等价于以批处理模式在输入表快照上执行的相同查询的结果

下图显示了流、动态表和连续查询之间的关系

在这里插入图片描述

  • 将流转换为动态表;
  • 在动态表上计算一个连续查询,生成一个新的动态表;
  • 生成的动态表被转换回流。

注意: 动态表是一个逻辑概念,在查询执行期间不一定(完全)物化动态表。

示例:单击事件流的动态表和连续查询

[
  user:  VARCHAR,   // 用户名
  cTime: TIMESTAMP, // 访问 URL 的时间
  url:   VARCHAR    // 用户访问的 URL
]

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

相关文章:

  • MySQL——子查询(5)带比较运算符的子查询
  • Leetcode Java学习记录——动态规划基础_2
  • Python | Leetcode Python题解之第378题有序矩阵中第K小的元素
  • EmguCV学习笔记 VB.Net 6.4 霍夫变换
  • eclipse下载安装与配置代码补全与中文版
  • 微软推出全新多语言高质量Phi-3.5语言模型
  • Vue组件的好处和理解、基本使用、注意事项、组件嵌套、VueComponent理解和原型链
  • Sweet Home 3D:Mac 与 Win 平台的强大 3D 室内装潢设计软件
  • Protect OpenAI key using Firebase function
  • 单片机的主流编程语言是什么
  • 实现简易 React SSR 框架
  • 最高加速超4倍!不依赖特定模型的统一模型压缩框架CPD发布(卡尔斯鲁厄理工学院)
  • 设计模式反模式:UML图示常见误用案例分析|设计模式|反模式|UML
  • 日本脸书Facebook代运营:如何投放广告与代运营合作全解析
  • NLP -->定义、应用、与职业前景解析
  • 开放式耳机别人能听到吗?不堵耳、不入耳的设计才舒服
  • 快速搭建和运行Spring Boot项目的简易指南
  • 数学建模学习(117):四阶龙格-库塔方法从理论到Python/matlab实践
  • 多线程篇(基本认识 - 线程相关API)(持续更新迭代)
  • 在WSL2中删除文件后,磁盘空间未释放怎么办