Add greater than operator for Q1
This commit is contained in:
parent
cc894e8ae3
commit
120527d072
@ -58,7 +58,7 @@ public class Project4 {
|
||||
JavaPairRDD<Integer, Rating> movieMatchRatings = usersRatingsJoin.mapToPair(t -> new Tuple2(t._2()._2().getMovieId(), t._2()._2()));
|
||||
JavaPairRDD<Integer, Tuple2<Rating, Movie>> moviesJoined = movieMatchRatings.join(filteredMoviesPair);
|
||||
|
||||
JavaRDD<String> movieIdRDD = moviesJoined.map(t -> t._1().toString()).distinct();
|
||||
JavaRDD<String> movieIdRDD = moviesJoined.map(t -> t._2()._2().getTitle().toString()).distinct();
|
||||
movieIdRDD.collect().forEach(x -> System.out.println(x));
|
||||
movieIdRDD.saveAsTextFile(CS448Utils.resolveUri(conf.outPath, "query-1"));
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user