茶网站建设宗旨,常州网站建设公司如何,如何做一名网站编辑,房地产集团网站欣赏2个DWD层 登录→kafka注册→kafka1个DWS 弄2条流#xff0c;从kafka读取数据将昨日注册数据存到状态中#xff0c;TTL为2天#xff0c;存到map状态中#xff0c;key为注册日期#xff0c;value为set#xff0c;存储注册的uid将登录流和注册流进行连接来一条登录数据…2个DWD层 登录→kafka注册→kafka1个DWS 弄2条流从kafka读取数据将昨日注册数据存到状态中TTL为2天存到map状态中key为注册日期value为set存储注册的uid将登录流和注册流进行连接来一条登录数据去注册状态中get昨天的日期然后判断登录的uid在不在set中如果在说明昨天注册的那么留存数加1get昨天的日期取set的size就是昨日注册数开一个10分钟的窗口每10分钟将留存数和昨日注册数存到Doris的当日分区中然后在ADS层计算0点至今的留存率留存数/昨日注册数大屏每10分钟刷新1次
