API
http://spark.apache.org/docs/1.6.2/api/java/index.html
机器学习里面包含两个包
org.apache.spark.ml #输入是dataframe,sql . org.apache.spark.sql.catalog
org.apache.spark.mllib
用户产品订单表,里面包含字段 用户id, 产品id, 是否购买来预测用户是否购买
//获取数据转换成RDD 1 hdfs 2SparkSql 3本地文件系统
context.textFile("/spark/file/user-order.txt") #hdfs中的路径
//RDD转换成ALS模型
ALS.train()
//把数据存储到mysql中版权声明:本文为xsjzdrxsjzdr原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。