通化網(wǎng)站制作,濟南特大最新消息,網(wǎng)頁游戲平臺制作,eclipse可以做網(wǎng)站嗎2個DWD層 登錄→kafka注冊→kafka1個DWS 弄2條流，從kafka讀取數(shù)據(jù)將昨日注冊數(shù)據(jù)存到狀態(tài)中，TTL為2天，存到map狀態(tài)中，key為注冊日期，value為set，存儲注冊的uid將登錄流和注冊流進行連接來一條登錄數(shù)據(jù)&…- 2個DWD層
- 登錄→kafka
- 注冊→kafka
- 1個DWS
- 弄2條流，從kafka讀取數(shù)據(jù)
- 將昨日注冊數(shù)據(jù)存到狀態(tài)中，TTL為2天，存到map狀態(tài)中，key為注冊日期，value為set，存儲注冊的uid
- 將登錄流和注冊流進行連接
- 來一條登錄數(shù)據(jù)，去注冊狀態(tài)中g(shù)et昨天的日期，然后判斷登錄的uid在不在set中，如果在，說明昨天注冊的，那么留存數(shù)加1
- get昨天的日期，取set的size，就是昨日注冊數(shù)
- 開一個10分鐘的窗口，每10分鐘將留存數(shù)和昨日注冊數(shù)存到Doris的當(dāng)日分區(qū)中，然后在ADS層計算0點至今的留存率=留存數(shù)/昨日注冊數(shù)
- 大屏每10分鐘刷新1次
