diff options
| author | Jacky Li <jacky.likun@huawei.com> | 2015-03-08 19:47:35 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-03-08 19:47:35 +0000 |
| commit | 55b1b32dc8b9b25deea8e5864b53fe802bb92741 (patch) | |
| tree | 48d63bf713d4c9f77e60604221d625a591e439fc /examples | |
| parent | f16b7b031feeb13ec9c17608bd99566f56431869 (diff) | |
| download | spark-55b1b32dc8b9b25deea8e5864b53fe802bb92741.tar.gz spark-55b1b32dc8b9b25deea8e5864b53fe802bb92741.tar.bz2 spark-55b1b32dc8b9b25deea8e5864b53fe802bb92741.zip | |
[GraphX] Improve LiveJournalPageRank example
1. Removed unnecessary import
2. Modified usage print since user must specify the --numEPart parameter as it is required in Analytics.main
Author: Jacky Li <jacky.likun@huawei.com>
Closes #4917 from jackylk/import and squashes the following commits:
6c07682 [Jacky Li] fix comment
c0df8f2 [Jacky Li] fix scalastyle
b6235e6 [Jacky Li] fix for comment
87be83b [Jacky Li] remove default value description
5caae76 [Jacky Li] remove import and modify usage
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/src/main/scala/org/apache/spark/examples/graphx/LiveJournalPageRank.scala | 9 |
1 files changed, 2 insertions, 7 deletions
diff --git a/examples/src/main/scala/org/apache/spark/examples/graphx/LiveJournalPageRank.scala b/examples/src/main/scala/org/apache/spark/examples/graphx/LiveJournalPageRank.scala index e809a65b79..f6f8d9f90c 100644 --- a/examples/src/main/scala/org/apache/spark/examples/graphx/LiveJournalPageRank.scala +++ b/examples/src/main/scala/org/apache/spark/examples/graphx/LiveJournalPageRank.scala @@ -17,11 +17,6 @@ package org.apache.spark.examples.graphx -import org.apache.spark.SparkContext._ -import org.apache.spark._ -import org.apache.spark.graphx._ - - /** * Uses GraphX to run PageRank on a LiveJournal social network graph. Download the dataset from * http://snap.stanford.edu/data/soc-LiveJournal1.html. @@ -31,13 +26,13 @@ object LiveJournalPageRank { if (args.length < 1) { System.err.println( "Usage: LiveJournalPageRank <edge_list_file>\n" + + " --numEPart=<num_edge_partitions>\n" + + " The number of partitions for the graph's edge RDD.\n" + " [--tol=<tolerance>]\n" + " The tolerance allowed at convergence (smaller => more accurate). Default is " + "0.001.\n" + " [--output=<output_file>]\n" + " If specified, the file to write the ranks to.\n" + - " [--numEPart=<num_edge_partitions>]\n" + - " The number of partitions for the graph's edge RDD. Default is 4.\n" + " [--partStrategy=RandomVertexCut | EdgePartition1D | EdgePartition2D | " + "CanonicalRandomVertexCut]\n" + " The way edges are assigned to edge partitions. Default is RandomVertexCut.") |