使用not exists提升性能 not exists是sql中的一个语法,常用在子查询和主查询之间,用于条件判断,根据一个条件返回一个布尔值,从而来确定下一步操作如何进行。 2022-07-13 浏览(138) 评论(0) 阅读全文
Spark Adaptive让 Spark SQL 更高效更智能 在不开启 Adaptive Execution 之前,执行计划一旦确定,即使发现后续执行计划可以优化,也不可更改。 2021-01-07 浏览(867) 评论(0) 阅读全文
Flink Flink 1.9 Table API& Sql支持的Data Type 1.9引入了全新的SQL的类型系统。以往的Table层的类型系统复用了Runtime的TypeInformation,但在实际操作过程当中遇到较多的限制。引入全新的SQL类型系统可以更好的对齐SQL语义。 2021-01-06 浏览(834) 评论(0) 阅读全文
Flink Flink Table API & SQL概念和通用API Apache Flink具有两个关系API-Table API和SQL-用于统一流和批处理。Table API是用于Scala和Java的语言集成查询API,它允许以非常直观的方式组合来自关系运算符(例如选择,过滤和联接)的查询。Flink的SQL支持基于实现SQL标准的Apache Calcite。无论输入是批处理输入DataSet还是流输入DataStream,在两个接口中指定的查询都具有相同 2021-01-06 浏览(1,452) 评论(0) 阅读全文