From 5478e716b9f080b7419285752708f0f4050f23da Mon Sep 17 00:00:00 2001 From: elmalto Date: Wed, 24 Sep 2014 11:34:45 -0700 Subject: [PATCH] logNormalGraph missing partition parameter --- docs/graphx-programming-guide.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/graphx-programming-guide.md b/docs/graphx-programming-guide.md index fdb9f98e214e5..eb861ddb50815 100644 --- a/docs/graphx-programming-guide.md +++ b/docs/graphx-programming-guide.md @@ -620,7 +620,7 @@ more senior followers of each user. import org.apache.spark.graphx.util.GraphGenerators // Create a graph with "age" as the vertex property. Here we use a random graph for simplicity. val graph: Graph[Double, Int] = - GraphGenerators.logNormalGraph(sc, numVertices = 100).mapVertices( (id, _) => id.toDouble ) + GraphGenerators.logNormalGraph(sc, numVertices = 100,sc.defaultParallelism).mapVertices( (id, _) => id.toDouble ) // Compute the number of older followers and their total age val olderFollowers: VertexRDD[(Int, Double)] = graph.mapReduceTriplets[(Int, Double)]( triplet => { // Map Function