diff --git a/p4/src/main/java/cs448/Project4.java b/p4/src/main/java/cs448/Project4.java index efd5f21..79b533e 100644 --- a/p4/src/main/java/cs448/Project4.java +++ b/p4/src/main/java/cs448/Project4.java @@ -131,6 +131,7 @@ public class Project4 { JavaPairRDD movieMatchRatings = usersRatingsJoin.mapToPair(t -> new Tuple2(t._2()._2().getMovieId(), t._2()._2())); JavaPairRDD> moviesJoined = movieMatchRatings.join(filteredMoviesPair); JavaRDD movieIdRDD = moviesJoined.map(t -> t._1().toString()); + movieIdRDD.collect().forEach(x -> System.out.println(x)); movieIdRDD.saveAsTextFile(CS448Utils.resolveUri(conf.outPath, "query-3")); // Dataset resultDF = spark.createDataFrame(movieIdRDD, Movie.class);