开发者社区> 问答> 正文

flink sql如何支持每隔5分钟触发当日零点到当前5分钟的聚合计算?

flink sql如何支持每隔5分钟触发当日零点到当前5分钟的聚合计算  hi all:有这样子一个场景,我想通过每隔5分钟统计当日零点到当前5分钟的pv和uv,用批处理大概大概表达如下: 

select    

 '2020-03-19' as dt ,   

 '2020-03-19 12:05:00'  as etltime , 

 count(1) as pv ,  

 count(distinct userid) as uv  

from t_user_log  

where  logintime  >= '2020-03-19 00:00:00' and logintime < '2020-03-19 12:05:00'  

这里,没法用flink sql 处理,当时这种场景又特别多,各位大神有好的方案处理吗?*来自志愿者整理的flink邮件归档

展开
收起
玛丽莲梦嘉 2021-12-02 16:34:32 1603 0
1 条回答
写回答
取消 提交回答
  • Hi 你可以看下这篇文章是否满足的你需求: 

    http://wuchong.me/blog/2020/02/25/demo-building-real-time-application-with-flink-sql 

    #统计一天每10分钟累计独立用户数*来自志愿者整理的FLINK邮件归档

    2021-12-02 17:31:51
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载