diff options
author | stayhf <chutong88@gmail.com> | 2013-08-06 21:03:24 +0000 |
---|---|---|
committer | stayhf <chutong88@gmail.com> | 2013-08-06 21:03:24 +0000 |
commit | 326a7a82e0fc7155d10af696ccca2e385134c144 (patch) | |
tree | 398735c6ae2039765fa74b3fef8f5b81d35df4b2 /examples/src | |
parent | 98fd62605daaf4e74dfffef1e7bc57ac131a61bb (diff) | |
download | spark-326a7a82e0fc7155d10af696ccca2e385134c144.tar.gz spark-326a7a82e0fc7155d10af696ccca2e385134c144.tar.bz2 spark-326a7a82e0fc7155d10af696ccca2e385134c144.zip |
changes as reviewer requested
Diffstat (limited to 'examples/src')
-rw-r--r-- | examples/src/main/java/spark/examples/JavaPageRank.java | 11 |
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); |