[ https://issues.apache.org/jira/browse/SPARK-8627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14601024#comment-14601024 ]
Subhod Lagade commented on SPARK-8627: -------------------------------------- can you help me in resolving this ?? usersProducts is a RDD(int,int) it is still giving me error > ALS model predict error > ----------------------- > > Key: SPARK-8627 > URL: https://issues.apache.org/jira/browse/SPARK-8627 > Project: Spark > Issue Type: Bug > Components: MLlib > Affects Versions: 1.4.0 > Reporter: Subhod Lagade > > /** > * Created by subhod lagade on 25/06/15. > */ > import org.apache.spark.SparkConf > import org.apache.spark.streaming.StreamingContext._ > import org.apache.spark.streaming.{Seconds, StreamingContext} > import org.apache.spark.streaming._; > import org.apache.spark.SparkContext > import org.apache.spark.SparkContext._ > import java.io.BufferedReader; > import java.io.FileInputStream; > import java.io.IOException; > import java.io.InputStreamReader; > import java.io.PrintStream; > import java.net.ServerSocket; > import java.net.Socket; > import java.util.Properties; > import org.apache.spark.mllib.recommendation.ALS > import org.apache.spark.mllib.recommendation.MatrixFactorizationModel > import org.apache.spark.mllib.recommendation.Rating > object SparkStreamKafka { > def main(args: Array[String]) { > > val conf = new SparkConf().setAppName("Simple Application"); > val sc = new SparkContext(conf); > val data = sc.textFile("/home/appadmin/Disney/data.csv"); > val ratings = data.map(_.split(',') match { case Array(user, product, > rate) => Rating(user.toInt, product.toInt, rate.toDouble) }); > > > val rank = 3; > val numIterations = 2; > val model = ALS.train(ratings,rank,numIterations,0.01); > > val usersProducts = ratings.map{ case Rating(user, product, rate) => > (user, product)} > // Build the recommendation model using ALS > usersProducts.foreach(println) > val predictions = model.predict(usersProducts) > } > } > /* > ERROR Message > [ERROR] > /home/appadmin/disneypoc/src/main/scala/org/capgemini/SparkKafka.scala:53: > error: not enough arguments for method predict: (user: Int, product: > Int)Double. > [INFO] Unspecified value parameter product. > [INFO] val predictions = model.predict(usersProducts) > */ -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org