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属地:
我来回答
您需要 登录 后回答此问题!