Apache Flink 漫谈系列 - 持续查询(Continuous Queries)

查询统计的变为，在计算具有相同订单数量的地区数量;查询SQL如下：

CREATE TABLE order_tab( 
id BIGINT, 
region VARCHAR 
) 
 
CREATE TABLE region_count_sink( 
order_cnt BIGINT, 
region_cnt BIGINT, 
PRIMARY KEY(order_cnt) -- 主键 
) 
 
-- 按地区分组计算每个地区的订单数量 
CREATE VIEW order_count_view AS 
SELECT 
region, count(id) AS order_cnt 
FROM order_tab 
GROUP BY region; 
 
-- 按订单数量分组统计具有相同订单数量的地区数量 
INSERT INTO region_count_sink 
SELECT 
order_cnt, 
count(region) as region_cnt 
FROM order_count_view 
GROUP BY order_cnt; 

（编辑：核心网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!