'请教下，flink sql where t条件是在内存过来，还是数据库中过滤的
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
在 Flink SQL 中，WHERE 条件是在 Flink 的执行引擎中过滤数据的，而不是在数据库中过滤数据的。具体来说，当您在 Flink SQL 中执行一个查询语句时，Flink 会将查询语句解析成逻辑计划，然后将逻辑计划转换成物理计划，最终在 Flink 的执行引擎中执行物理计划。
在执行物理计划时，Flink 会将数据从数据源中读取到内存中，然后在内存中进行 WHERE 条件的过滤操作。这个过程是在 Flink 的执行引擎中进行的，而不是在数据源中进行的。因此，WHERE 条件的过滤操作不会对数据源造成负载压力，也不会影响数据源的性能。
需要注意的是，如果您在 Flink SQL 中使用了比较复杂的 WHERE 条件，例如使用了聚合函数、窗口函数等，可能会导致 Flink 在执行查询时需要大
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
评论
全部评论 (0)