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