如何在FlinkSQL中按周聚合数据

Question

如果我想按天聚合数据分组，sql：

select
DATE_FORMAT(ctime, 'yyyyMMdd'),
count(*) as num
from event
group by DATE_FORMAT(ctime, 'yyyyMMdd');

如何按周分组汇总数据？

Answer 1

您可以使用以下命令按周进行聚合：

SELECT date_format(ctime,'YYYYw'),
       count(*) AS num
FROM event
GROUP BY date_format(ctime,'YYYYw')

date_format函数支持任何与Java的SimpleDateFormat兼容的格式字符串。