FlinkSQL中如何定义和使用视图(VIEW)?

提问者:帅平 问题分类:面试刷题
FlinkSQL中如何定义和使用视图(VIEW)?
2 个回答
冷清°
冷清°
创建视图
-- 创建临时视图
-- 创建基于Kafka订单表的聚合视图
CREATE TEMPORARY VIEW kafka_order_stats AS
SELECT 
  user_id, 
  TUMBLE_START(event_time, INTERVAL '10' SECOND) AS window_start,
  SUM(amount) AS total_amount
FROM kafka_orders
GROUP BY user_id, TUMBLE(event_time, INTERVAL '10' SECOND);
--创建永久视图
-- 在Hive Catalog中创建永久视图
CREATE VIEW hive_db.user_orders AS
SELECT 
  o.order_id, 
  u.name, 
  o.amount 
FROM hive_orders o
JOIN jdbc_users u ON o.user_id = u.user_id;
发布于:1周前 (05-28) IP属地:
人潮似水看见我°
人潮似水看见我°
查询视图
-- 直接查询视图,而非编写冗长的JOIN和GROUP BY
SELECT window_start, SUM(total_amount)
FROM kafka_order_stats
GROUP BY window_start;
发布于:1周前 (05-28) IP属地:
我来回答