From 31a704004f9b4ad34f92ae5c95ae6e90d0ab62c7 Mon Sep 17 00:00:00 2001
From: jianghan <jianghan@xiaomi.com>
Date: Wed, 12 Mar 2014 19:46:12 -0700
Subject: [PATCH] Fix example bug: compile error

Author: jianghan <jianghan@xiaomi.com>

Closes #132 from pooorman/master and squashes the following commits:

54afbe0 [jianghan] Fix example bug: compile error
---
 .../main/java/org/apache/spark/examples/JavaLogQuery.java   | 2 +-
 .../main/java/org/apache/spark/examples/JavaPageRank.java   | 6 +++---
 .../main/java/org/apache/spark/examples/JavaWordCount.java  | 2 +-
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/examples/src/main/java/org/apache/spark/examples/JavaLogQuery.java b/examples/src/main/java/org/apache/spark/examples/JavaLogQuery.java
index a518fe2f27..617e4a6d04 100644
--- a/examples/src/main/java/org/apache/spark/examples/JavaLogQuery.java
+++ b/examples/src/main/java/org/apache/spark/examples/JavaLogQuery.java
@@ -124,7 +124,7 @@ public final class JavaLogQuery {
 
     List<Tuple2<Tuple3<String, String, String>, Stats>> output = counts.collect();
     for (Tuple2<?,?> t : output) {
-      System.out.println(t._1 + "\t" + t._2);
+      System.out.println(t._1() + "\t" + t._2());
     }
     System.exit(0);
   }
diff --git a/examples/src/main/java/org/apache/spark/examples/JavaPageRank.java b/examples/src/main/java/org/apache/spark/examples/JavaPageRank.java
index e53925b50c..eb70fb5475 100644
--- a/examples/src/main/java/org/apache/spark/examples/JavaPageRank.java
+++ b/examples/src/main/java/org/apache/spark/examples/JavaPageRank.java
@@ -90,8 +90,8 @@ public final class JavaPageRank {
           @Override
           public Iterable<Tuple2<String, Double>> call(Tuple2<List<String>, Double> s) {
             List<Tuple2<String, Double>> results = new ArrayList<Tuple2<String, Double>>();
-            for (String n : s._1) {
-              results.add(new Tuple2<String, Double>(n, s._2 / s._1.size()));
+            for (String n : s._1()) {
+              results.add(new Tuple2<String, Double>(n, s._2() / s._1().size()));
             }
             return results;
           }
@@ -109,7 +109,7 @@ public final class JavaPageRank {
     // Collects all URL ranks and dump them to console.
     List<Tuple2<String, Double>> output = ranks.collect();
     for (Tuple2<?,?> tuple : output) {
-        System.out.println(tuple._1 + " has rank: " + tuple._2 + ".");
+        System.out.println(tuple._1() + " has rank: " + tuple._2() + ".");
     }
 
     System.exit(0);
diff --git a/examples/src/main/java/org/apache/spark/examples/JavaWordCount.java b/examples/src/main/java/org/apache/spark/examples/JavaWordCount.java
index fa1b977ab1..3ae1d8f7ca 100644
--- a/examples/src/main/java/org/apache/spark/examples/JavaWordCount.java
+++ b/examples/src/main/java/org/apache/spark/examples/JavaWordCount.java
@@ -65,7 +65,7 @@ public final class JavaWordCount {
 
     List<Tuple2<String, Integer>> output = counts.collect();
     for (Tuple2<?,?> tuple : output) {
-      System.out.println(tuple._1 + ": " + tuple._2);
+      System.out.println(tuple._1() + ": " + tuple._2());
     }
     System.exit(0);
   }
-- 
GitLab