diff --git a/p4/src/main/java/cs448/Project4.java b/p4/src/main/java/cs448/Project4.java index 04853fe..ea2d11e 100644 --- a/p4/src/main/java/cs448/Project4.java +++ b/p4/src/main/java/cs448/Project4.java @@ -55,7 +55,10 @@ public class Project4 { Dataset resultDF = spark.sql("SELECT DISTINCT m.title FROM Movie m, Rating r, User u WHERE m.movieId = r.movieId AND r.userId = u.userId AND u.occupation = " + conf.q1Occupation + " AND r.rating >= " + conf.q1Rating); - resultDF.show(); + //resultDF.show(); + resultDF.foreach(x -> System.out.println(x.getString(0))); + resultDF.write().text(CS448Utils.resolveUri(conf.outPath)); + //Don't forget to stop spark session spark.stop();