如何在FlinkSQL中实现多维分析(OLAP)场景的窗口操作?

提问者:帅平 问题分类:大数据
如何在FlinkSQL中实现多维分析(OLAP)场景的窗口操作?
2 个回答
青衫烟雨べ故人归
青衫烟雨べ故人归
滑动窗口+多维度下钻
-- 每5分钟统计过去1小时的累计销售额,按地区和产品下钻
SELECT 
  HOP_START(event_time, INTERVAL '5' MINUTE, INTERVAL '1' HOUR) AS hop_window,
  region,
  product_id,
  SUM(amount) AS cumulative_sales
FROM sales_events
GROUP BY 
  HOP(event_time, INTERVAL '5' MINUTE, INTERVAL '1' HOUR),
  region,
  product_id;
发布于:3周前 (05-28) IP属地:
我就这样
我就这样
多维度分组+时间窗口聚合
-- 按小时、地区、产品类别统计销售额
SELECT 
  TUMBLE_START(event_time, INTERVAL '1' HOUR) AS hour_window,
  region,
  product_category,
  SUM(amount) AS total_sales
FROM sales_events
GROUP BY 
  TUMBLE(event_time, INTERVAL '1' HOUR),
  region,
  product_category;
发布于:3周前 (05-28) IP属地:
我来回答