IT评测·应用市场-qidao123.com技术社区
标题:
10、Flink 动态表之查询限定详解
[打印本页]
作者:
笑看天下无敌手
时间:
2024-8-28 10:47
标题:
10、Flink 动态表之查询限定详解
查询限定
许多(非全部)语义上有效的查询可以作为流上的连续查询进行评估,有些查询代价太高而无法计算,这大概是由于它们须要维护的状态大小,也大概是由于计算更新代价太高。
状态大小:
连续查询在无界流上计算,通常应该运行数周或数月。因此连续查询处理处罚的数据总量大概非常大,
必须更新先前输出的结果的查询须要维护全部输出的行,以便能够更新它们
;例如第一个查询示例须要存储每个用户的 URL 计数,以便能够增加该计数并在输入表接收新行时发送新结果;假如只跟踪注册用户,则要维护的计数数量大概不会太高;但是假如未注册的用户分配了一个惟一的用户名,那么要维护的计数数量将随着时间增长,并大概终极导致查询失败。
SELECT user, COUNT(url)
复制代码
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。
欢迎光临 IT评测·应用市场-qidao123.com技术社区 (https://dis.qidao123.com/)
Powered by Discuz! X3.4