文件名称：recommend:基于亚马逊商品表 和用户评分表的 电商推荐系统
文件大小：7.59MB
文件格式：ZIP
更新时间：2024-05-30 00:40:06
HTML
电商推荐系统 项目启动组件: Redis kafka flume ./bin/flume-ng agent --conf conf --conf-file ./conf/recommend-kafka-flume.conf --name a1 -Dflume.root.logger=info,console MongoDB KafkaStreamApplication //不需要启用该组件了. 定义了Flume Interceptor拦截器来清洗日志.把不同的日志分到不同的kafka topic里面. OnLineRecommender business-server 数据加载模块 data-loader 读取 商品数据文件和用户评分数据文件 解析后初始化到MongoDB.直接用spark DataFrame的write方法写入到MongoDB 数据初始化模块 statistics-rec