建设网站代理商,深圳个性化网站建设公司,哪里有网络推广公司,企业系统建设Flink系列之#xff1a;集合操作 一、集合操作二、UNION三、INTERSECT四、EXCEPT五、IN六、EXISTS 一、集合操作
适用于流、批操作
二、UNION
UNION 和 UNION ALL 返回两个表中的数据。 UNION 会去重#xff0c;UNION ALL 不会去重。
Flink SQL create view t1(s) as… Flink系列之集合操作 一、集合操作二、UNION三、INTERSECT四、EXCEPT五、IN六、EXISTS 一、集合操作
适用于流、批操作
二、UNION
UNION 和 UNION ALL 返回两个表中的数据。 UNION 会去重UNION ALL 不会去重。
Flink SQL create view t1(s) as values (c), (a), (b), (b), (c);
Flink SQL create view t2(s) as values (d), (e), (a), (b), (b);Flink SQL (SELECT s FROM t1) UNION (SELECT s FROM t2);
---
| s|
---
| c|
| a|
| b|
| d|
| e|
---Flink SQL (SELECT s FROM t1) UNION ALL (SELECT s FROM t2);
---
| c|
---
| c|
| a|
| b|
| b|
| c|
| d|
| e|
| a|
| b|
| b|
---三、INTERSECT
INTERSECT 和 INTERSECT ALL 返回两个表中共有的数据。 INTERSECT 会去重INTERSECT ALL 不会去重。
Flink SQL (SELECT s FROM t1) INTERSECT (SELECT s FROM t2);
---
| s|
---
| a|
| b|
---Flink SQL (SELECT s FROM t1) INTERSECT ALL (SELECT s FROM t2);
---
| s|
---
| a|
| b|
| b|
---四、EXCEPT
EXCEPT 和 EXCEPT ALL 返回在一个表中存在但在另一个表中不存在数据。 EXCEPT 会去重EXCEPT ALL不会去重。
Flink SQL (SELECT s FROM t1) EXCEPT (SELECT s FROM t2);
---
| s |
---
| c |
---Flink SQL (SELECT s FROM t1) EXCEPT ALL (SELECT s FROM t2);
---
| s |
---
| c |
| c |
---五、IN
如果表达式可以是列也可以是函数等存在于子查询的结果中则返回 true。子查询的表结果必须由一列组成。此列必须与表达式具有相同的数据类型。
SELECT user, amount
FROM Orders
WHERE product IN (SELECT product FROM NewProducts
)优化器会把 IN 条件重写为 join 和 group 操作。对于流式查询计算查询结果所需的状态可能会根据输入行数而无限增长。你可以设置一个合适的状态 time-to-liveTTL来淘汰过期数据以防止状态过大。注意这可能会影响查询结果的正确性。
六、EXISTS
SELECT user, amount
FROM Orders
WHERE product EXISTS (SELECT product FROM NewProducts
)如果子查询返回至少一行则为 true。只支持能被重写为 join 和 group 的操作。
优化器会把 EXIST 重写为 join 和 group 操作.对于流式查询计算查询结果所需的状态可能会根据输入行数而无限增长。你可以设置一个合适的状态 time-to-liveTTL来淘汰过期数据以防止状态过大。注意这可能会影响查询结果的正确性。
