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

10、Flink 动态表之查询限制详解

查询限制

许多(非全部)语义上有效的查询可以作为流上的连续查询进行评估,有些查询代价太高而无法计算,这可能是由于它们需要维护的状态大小,也可能是由于计算更新代价太高。

  • 状态大小: 连续查询在无界流上计算,通常应该运行数周或数月。因此连续查询处理的数据总量可能非常大,必须更新先前输出的结果的查询需要维护所有输出的行,以便能够更新它们;例如第一个查询示例需要存储每个用户的 URL 计数,以便能够增加该计数并在输入表接收新行时发送新结果;如果只跟踪注册用户,则要维护的计数数量可能不会太高;但是如果未注册的用户分配了一个惟一的用户名,那么要维护的计数数量将随着时间增长,并可能最终导致查询失败。
SELECT user, COUNT(url)

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

相关文章:

  • XXE-labs靶场通关攻略
  • Github 2024-08-23 Java开源项目日报 Top9
  • 数学建模学习(121):Python实现模糊AHP(Fuzzy AHP)——从原理到实践
  • Word中设置奇数页的页眉为一级标题内容;偶数页的页眉为文章题目
  • Android - 音频参数合入
  • 【kubernetes】kubernetes Deployment 详解
  • 【ElasticSearch】基本命令
  • 波导阵列天线学习笔记6 用于K和Ka频段卫星通信的超宽带双圆极化波导阵列天线
  • Django后端架构开发:缓存机制,接口缓存、文件缓存、数据库缓存与Memcached缓存
  • CI/CD实践(四)Jenkins部署及环境配置
  • 小程序封装接口请求
  • 信息打点-系统篇端口扫描CDN服务负载均衡WAF防火墙
  • Java中Stream流详解
  • 深度学习500问——Chapter13:优化算法(2)
  • 孟德尔随机化-装包TwoSampleMR的两种方法
  • 前端技术(五)—— 使用Node.js编写简单的项目
  • flink 状态参数设置
  • SQL 注入之 WAF 绕过
  • 有了nova Flip,个性出圈自拍照,轻松拿捏!
  • Nginx + Docker Compose前后端分离部署到服务器过程记录