You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/03/13 03:46:34 UTC
git commit: Fix example bug: compile error
Repository: spark
Updated Branches:
refs/heads/master 9032f7c0d -> 31a704004
Fix example bug: compile error
Author: jianghan <ji...@xiaomi.com>
Closes #132 from pooorman/master and squashes the following commits:
54afbe0 [jianghan] Fix example bug: compile error
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/31a70400
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/31a70400
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/31a70400
Branch: refs/heads/master
Commit: 31a704004f9b4ad34f92ae5c95ae6e90d0ab62c7
Parents: 9032f7c
Author: jianghan <ji...@xiaomi.com>
Authored: Wed Mar 12 19:46:12 2014 -0700
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Wed Mar 12 19:46:12 2014 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/spark/examples/JavaLogQuery.java | 2 +-
.../src/main/java/org/apache/spark/examples/JavaPageRank.java | 6 +++---
.../src/main/java/org/apache/spark/examples/JavaWordCount.java | 2 +-
3 files changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/31a70400/examples/src/main/java/org/apache/spark/examples/JavaLogQuery.java
----------------------------------------------------------------------
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 a518fe2..617e4a6 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);
}
http://git-wip-us.apache.org/repos/asf/spark/blob/31a70400/examples/src/main/java/org/apache/spark/examples/JavaPageRank.java
----------------------------------------------------------------------
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 e53925b..eb70fb5 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);
http://git-wip-us.apache.org/repos/asf/spark/blob/31a70400/examples/src/main/java/org/apache/spark/examples/JavaWordCount.java
----------------------------------------------------------------------
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 fa1b977..3ae1d8f 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);
}