Please following the code examples from the user guide:
http://spark.apache.org/docs/latest/programming-guide.html#passing-functions-to-spark.
-Xiangrui
On Tue, May 26, 2015 at 12:34 AM, Yasemin Kaya godo...@gmail.com wrote:
Hi,
In CF
String path = data/mllib/als/test.data;
JavaRDDString
Hi,
In CF
String path = data/mllib/als/test.data;
JavaRDDString data = sc.textFile(path);
JavaRDDRating ratings = data.map(new FunctionString, Rating() {
public Rating call(String s) {
String[] sarray = s.split(,);
return new Rating(Integer.parseInt(sarray[0]), Integer
.parseInt(sarray[1]),
