快手一道场景题目
拼接用户的点击和展现日志(先有展现日志,后有点击日志),点击日志存到kafka A,展现日志存到kafka B,现在要分别从这两个kafka里边取数据,根据展现id进行匹配,拼接成点展日志,最后写入kafka C,时间窗口是一小时(最多允许点击日志迟到一小时,否则就不再匹配)。
我的思路:
从kafka B读取展现日志,存入到map里,key是展现id,value是日志的内容,然后从kafka A里读取点击日志,和map的key进行匹配,如果匹配到进行拼接,匹配不到就意味着有点击日志但没有展现日志,说明超出了时间窗口,应该被丢弃。
有定时器判断map中的key是否超出一小时,如果超出则清除出map。
这个思路是否有问题?有没有更好的思路#牛客AI配图神器#
#面经#
我的思路:
从kafka B读取展现日志,存入到map里,key是展现id,value是日志的内容,然后从kafka A里读取点击日志,和map的key进行匹配,如果匹配到进行拼接,匹配不到就意味着有点击日志但没有展现日志,说明超出了时间窗口,应该被丢弃。
有定时器判断map中的key是否超出一小时,如果超出则清除出map。
这个思路是否有问题?有没有更好的思路#牛客AI配图神器#
#面经#
全部评论
啥部门
相关推荐
点赞 评论 收藏
分享
smile丶snow:尽量保证的一张a4纸吧。为什么工作经历只有公司?如果项目经历是工作里面的,应该写到工作经历里的吧。没有写项目职责,项目全是一个人写的吗?标题大小也好怪。两个项目的分割看不出来是,它和那些项目成功字体是一样大的 点赞 评论 收藏
分享
rush$0522:转正名单没进,大概率本来就没打算留你 点赞 评论 收藏
分享
阿里云成长空间 772人发布