将各个渠道的天活跃结果入库
把渠道的新增加起来并入库
统计各个渠道的新增 group by appkey
把渠道的小时的活跃加起来并入库
小时活跃用户入库device_id
device_id去重
过滤出活跃天用户
过滤出活跃小时用户
接收kafaka数据
新增用户入库device_id
将各个渠道的小时活跃结果入库
格式化数据
统计各个渠道小时的活跃 group by appkey
统计各个渠道天的活跃 group by appkey
把渠道的天的活跃加起来并入库
将各个渠道的结果入库
天活跃用户入库
开始
过滤出新增用户