From 367a7bd713dea67ce73456f5e86ae6639c30b264 Mon Sep 17 00:00:00 2001
From: Max O'Cull <max.ocull@protonmail.com>
Date: Sat, 20 Apr 2019 23:30:35 -0400
Subject: [PATCH] Fix double cast

---
 p4/src/main/java/cs448/Project4.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/p4/src/main/java/cs448/Project4.java b/p4/src/main/java/cs448/Project4.java
index 83391b6..31b91f0 100644
--- a/p4/src/main/java/cs448/Project4.java
+++ b/p4/src/main/java/cs448/Project4.java
@@ -180,7 +180,7 @@ public class Project4 {
         // conf.q4Age);
         Dataset<Row> resultDF = spark.sql(
                 "SELECT m.title, AVG(r.rating) FROM Movie m, Rating r, User u WHERE m.movieId = r.movieId AND r.userId = u.userId AND u.age = " + conf.q4Age + " GROUP BY m.title");
-        Dataset<String> CompressedResult = resultDF.map((MapFunction<Row, String>) row -> row.getString(0) + "::" + row.getDecimal(1), Encoders.STRING());
+        Dataset<String> CompressedResult = resultDF.map((MapFunction<Row, String>) row -> row.getString(0) + "::" + row.getDouble(1), Encoders.STRING());
         CompressedResult.show();
         CompressedResult.write().text(CS448Utils.resolveUri(conf.outPath, "query-4"));