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

查询限定

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

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

1. SELECT user, COUNT(url)

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。