如何在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兼容的格式字符串。