diff options
| author | CrazyJvm <crazyjvm@gmail.com> | 2014-07-11 00:02:24 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-07-11 00:02:24 -0700 |
| commit | 282cca0e49120291759ded75709013e907db598c (patch) | |
| tree | b04d77fc3cea77782b29bf6c4ed1e41d7abc0041 /graphx/src/main/scala/org/apache | |
| parent | 2f59ce7dbe2fe2ff31e2629bb34572d39098d638 (diff) | |
| download | spark-282cca0e49120291759ded75709013e907db598c.tar.gz spark-282cca0e49120291759ded75709013e907db598c.tar.bz2 spark-282cca0e49120291759ded75709013e907db598c.zip | |
fix Graph partitionStrategy comment
Author: CrazyJvm <crazyjvm@gmail.com>
Closes #1368 from CrazyJvm/graph-comment-1 and squashes the following commits:
d47f3c5 [CrazyJvm] fix style
e190d6f [CrazyJvm] fix Graph partitionStrategy comment
Diffstat (limited to 'graphx/src/main/scala/org/apache')
| -rw-r--r-- | graphx/src/main/scala/org/apache/spark/graphx/Graph.scala | 6 | ||||
| -rw-r--r-- | graphx/src/main/scala/org/apache/spark/graphx/VertexRDD.scala | 4 |
2 files changed, 6 insertions, 4 deletions
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/Graph.scala b/graphx/src/main/scala/org/apache/spark/graphx/Graph.scala index 4db45c9af8..3507f358bf 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/Graph.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/Graph.scala @@ -107,14 +107,16 @@ abstract class Graph[VD: ClassTag, ED: ClassTag] protected () extends Serializab /** * Repartitions the edges in the graph according to `partitionStrategy`. * - * @param the partitioning strategy to use when partitioning the edges in the graph. + * @param partitionStrategy the partitioning strategy to use when partitioning the edges + * in the graph. */ def partitionBy(partitionStrategy: PartitionStrategy): Graph[VD, ED] /** * Repartitions the edges in the graph according to `partitionStrategy`. * - * @param the partitioning strategy to use when partitioning the edges in the graph. + * @param partitionStrategy the partitioning strategy to use when partitioning the edges + * in the graph. * @param numPartitions the number of edge partitions in the new graph. */ def partitionBy(partitionStrategy: PartitionStrategy, numPartitions: Int): Graph[VD, ED] diff --git a/graphx/src/main/scala/org/apache/spark/graphx/VertexRDD.scala b/graphx/src/main/scala/org/apache/spark/graphx/VertexRDD.scala index f1b6df9a30..4825d12fc2 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/VertexRDD.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/VertexRDD.scala @@ -182,8 +182,8 @@ class VertexRDD[@specialized VD: ClassTag]( /** * Left joins this RDD with another VertexRDD with the same index. This function will fail if * both VertexRDDs do not share the same index. The resulting vertex set contains an entry for - * each - * vertex in `this`. If `other` is missing any vertex in this VertexRDD, `f` is passed `None`. + * each vertex in `this`. + * If `other` is missing any vertex in this VertexRDD, `f` is passed `None`. * * @tparam VD2 the attribute type of the other VertexRDD * @tparam VD3 the attribute type of the resulting VertexRDD |