实时推荐算法数据处理流程

Redis

过滤

是否是有效行为

基于标签召回

Hbase物品-物品相似表(dp_zy_items_simi)

Kafka(dp_rt_log)

基于物品召回（itemcf相似）

SparkStreaming

基于物品召回（content相似）

多样性排序

过滤掉

Hbase作业任务-作业任务相似表(dp_zy_task_simi)

否

Hbase标签-热门作业对应表dp_zy_label_hotzy

汇总得分

Hbase作业任务-标签对应表(dp_zy_task_label)

模型融合

Hbase作业任务-热门作业对应表(dp_zy_task_hotzy)

是

Hbase作业基础信息表(dp_zy_info)

行为打分