相关文章推荐
温文尔雅的汤圆  ·  The generic type ...·  1 周前    · 
神勇威武的草稿本  ·  为什么Flink ...·  3 天前    · 
含蓄的四季豆  ·  Asserting Log ...·  4 月前    · 
痴情的数据线  ·  shell 读取json数组-掘金·  1 年前    · 
可爱的烈马  ·  Object.assign()解决vue2中 ...·  1 年前    · 

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邮件归档

Hi 你可以看下这篇文章是否满足的你需求:

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

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

2021-12-02 17:31:51 企业邮箱发送邮件时,若出现投递失败产生退信,内容提示包含如下: the mta server of * reply:550 failed to meet SPF requirements 或者 the mta server of 163.com — 163mx01.mxmail.netease.com(220.181.14.141) reply:550 MI:SPF mx14,QMCowECpA0qTiftVaeB3Cg—.872S2 1442548128 http://mail.163.com/help 299645