aboutsummaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorstayhf <chutong88@gmail.com>2013-08-06 21:03:24 +0000
committerstayhf <chutong88@gmail.com>2013-08-06 21:03:24 +0000
commit326a7a82e0fc7155d10af696ccca2e385134c144 (patch)
tree398735c6ae2039765fa74b3fef8f5b81d35df4b2 /examples
parent98fd62605daaf4e74dfffef1e7bc57ac131a61bb (diff)
downloadspark-326a7a82e0fc7155d10af696ccca2e385134c144.tar.gz
spark-326a7a82e0fc7155d10af696ccca2e385134c144.tar.bz2
spark-326a7a82e0fc7155d10af696ccca2e385134c144.zip
changes as reviewer requested
Diffstat (limited to 'examples')
-rw-r--r--examples/src/main/java/spark/examples/JavaPageRank.java11
1 files changed, 1 insertions, 10 deletions
diff --git a/examples/src/main/java/spark/examples/JavaPageRank.java b/examples/src/main/java/spark/examples/JavaPageRank.java
index b57797a9fb..8e58bf2433 100644
--- a/examples/src/main/java/spark/examples/JavaPageRank.java
+++ b/examples/src/main/java/spark/examples/JavaPageRank.java
@@ -46,15 +46,6 @@ public class JavaPageRank {
return out;
}
- public static double round(double value, int places) {
- if (places < 0) throw new IllegalArgumentException();
-
- long factor = (long) Math.pow(10, places);
- value = value * factor;
- long tmp = Math.round(value);
- return (double) tmp / factor;
- }
-
public static void main(String[] args) throws Exception {
if (args.length < 3) {
System.err.println("Usage: JavaPageRank <master> <file> <number_of_iterations>");
@@ -121,7 +112,7 @@ public 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: " + round((Double)(tuple._2), 2) + ".");
+ System.out.println(tuple._1 + " has rank: " + tuple._2 + ".");
}
System.exit(0);