improve AverageHousePriceSolution and AvgCount

Author: James Lee

src/main/java/com/sparkTutorial/pairRdd/aggregation/reducebykey/WordCount.java

@@ -29,7 +29,9 @@ public static void main(String[] args) throws Exception {
 
         JavaPairRDD<String, Integer> wordCounts = wordPairRdd.reduceByKey((Function2<Integer, Integer, Integer>) (x, y) -> x + y);
 
-        for (Map.Entry<String, Integer> wordCountPair : wordCounts.collectAsMap().entrySet()) {
+        Map<String, Integer> worldCountsMap = wordCounts.collectAsMap();
+
+        for (Map.Entry<String, Integer> wordCountPair : worldCountsMap.entrySet()) {
             System.out.println(wordCountPair.getKey() + " : " + wordCountPair.getValue());
 
         }

src/main/java/com/sparkTutorial/pairRdd/aggregation/reducebykey/housePrice/AverageHousePriceSolution.java

@@ -34,11 +34,17 @@ public static void main(String[] args) throws Exception {
                 (Function2<AvgCount, AvgCount, AvgCount>) (x, y) ->
                 new AvgCount(x.getCount() + y.getCount(), x.getTotal() + y.getTotal()));
 
+        System.out.println("housePriceTotal: ");
+        for (Map.Entry<String, AvgCount> housePriceTotalPair : housePriceTotal.collectAsMap().entrySet()) {
+            System.out.println(housePriceTotalPair.getKey() + " : " + housePriceTotalPair.getValue());
+
+        }
 
         JavaPairRDD<String, Double> housePriceAvg = housePriceTotal.mapToPair(
                 (PairFunction<Tuple2<String, AvgCount>, String, Double>) total ->
                  new Tuple2<>(total._1(), total._2().getTotal()/total._2().getCount()));
 
+        System.out.println("housePriceAvg: ");
         for (Map.Entry<String, Double> housePriceAvgPair : housePriceAvg.collectAsMap().entrySet()) {
             System.out.println(housePriceAvgPair.getKey() + " : " + housePriceAvgPair.getValue());
 

src/main/java/com/sparkTutorial/pairRdd/aggregation/reducebykey/housePrice/AvgCount.java

@@ -18,4 +18,12 @@ public int getCount() {
     public double getTotal() {
         return total;
     }
+
+    @Override
+    public String toString() {
+        return "AvgCount{" +
+                "count=" + count +
+                ", total=" + total +
+                '}';
+    }
 }