Hi, In CF
String path = "data/mllib/als/test.data"; JavaRDD<String> data = sc.textFile(path); JavaRDD<Rating> ratings = data.map(new Function<String, Rating>() { public Rating call(String s) { String[] sarray = s.split(","); return new Rating(Integer.parseInt(sarray[0]), Integer .parseInt(sarray[1]), Double.parseDouble(sarray[2])); } }); implemented like that. I want to use CF for my data set, but it is JavaPairRDD<String, List<Integer>> . How can I convert my dataset to JavaRDD<Rating>. Thank you.. Best, yasemin -- hiç ender hiç