flink sql嵌套查询
时间: 2023-09-02 18:11:45 浏览: 265
Flink 同步数据+mongo<->hive+支持复杂类型
Flink SQL 支持嵌套查询,可以在一个查询语句中包含另一个查询语句。下面是一个示例:
```
SELECT col1, col2 FROM (
SELECT col1, COUNT(*) AS col2 FROM table1 GROUP BY col1
) t WHERE t.col2 > 1
```
在这个例子中,内部查询语句计算每个 col1 值的行数,然后外部查询语句过滤出行数大于 1 的结果。
需要注意的是,在 Flink SQL 中,嵌套查询必须使用子查询的方式,即将内部查询放在括号中,并且为其指定一个别名。在外部查询中,可以使用别名来引用内部查询的结果。
阅读全文