diff --git a/p4/src/main/java/cs448/Project4.java b/p4/src/main/java/cs448/Project4.java index ea2d11e..49c2bc3 100644 --- a/p4/src/main/java/cs448/Project4.java +++ b/p4/src/main/java/cs448/Project4.java @@ -57,7 +57,7 @@ public class Project4 { conf.q1Occupation + " AND r.rating >= " + conf.q1Rating); //resultDF.show(); resultDF.foreach(x -> System.out.println(x.getString(0))); - resultDF.write().text(CS448Utils.resolveUri(conf.outPath)); + resultDF.write().text(CS448Utils.resolveUri(conf.outPath, "query-1")); //Don't forget to stop spark session