做网站会出现什么问题,做cover用什么网站,做 英语试题的网站,哪有网站建设明细报价表一、基于物品的推荐公式 其中#xff0c;S(j,K)表示与物品j最相似的K个物品#xff0c;N(u)表示用户u喜欢的物品集合#xff0c;Rui表示用户u对物品i的评分。 二、代码
public class ItemCFRecommendApp {public static void main(String[]args){SparkConf sparkConf new …一、基于物品的推荐公式 其中S(j,K)表示与物品j最相似的K个物品N(u)表示用户u喜欢的物品集合Rui表示用户u对物品i的评分。 二、代码
public class ItemCFRecommendApp {public static void main(String[]args){SparkConf sparkConf new SparkConf();sparkConf.setAppName(ItemCFRecommendApp);sparkConf.setMaster(local[*]);SparkSession sparkSession SparkSession.builder().config(sparkConf).getOrCreate();String url jdbc:mysql://localhost:3306/spark-mysql?useUnicodetruecharacterEncodingutf8autoReconnecttruefailOverReadOnlyfalse;String driver com.mysql.jdbc.Driver;String user root;String password admin;DatasetRow score sparkSession.read().format(jdbc).option(driver, driver).option(url,url).option(dbtable,user_item).option(user,user).option(password,password).load();DatasetRow similar sparkSession.read().format(jdbc).option(driver, driver).option(url,url).option(dbtable,item_similar).option(user,user).option(password,password).load();//分组 top k
// similar similar.selectExpr(a_item_id, b_item_id, count,
// ROW_NUMBER() OVER (PARTITION BY a_item_id ORDER BY count DESC) rank)
// .where(rank 10);
// similar.show();DatasetRow result similar.as(is).join(score.as(s), functions.column(is.b_item_id).$eq$eq$eq(functions.column(s.item_id))).selectExpr(is.a_item_id item_id, s.user_id, is.count * s.score score).groupBy(user_id, item_id).sum(score).selectExpr(user_id, item_id, sum(score) score);result.show();
// result.write()
// .mode(SaveMode.Overwrite)
// .format(jdbc)
// .option(driver, driver)
// .option(url,url)
// .option(dbtable,item_user_recom)
// .option(user,user)
// .option(password,password)
// .save();sparkSession.stop();}
}
