Skip to content
Snippets Groups Projects
Commit 282cca0e authored by CrazyJvm's avatar CrazyJvm Committed by Reynold Xin
Browse files

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
parent 2f59ce7d
No related branches found
No related tags found
No related merge requests found
...@@ -107,14 +107,16 @@ abstract class Graph[VD: ClassTag, ED: ClassTag] protected () extends Serializab ...@@ -107,14 +107,16 @@ abstract class Graph[VD: ClassTag, ED: ClassTag] protected () extends Serializab
/** /**
* Repartitions the edges in the graph according to `partitionStrategy`. * 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] def partitionBy(partitionStrategy: PartitionStrategy): Graph[VD, ED]
/** /**
* Repartitions the edges in the graph according to `partitionStrategy`. * 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. * @param numPartitions the number of edge partitions in the new graph.
*/ */
def partitionBy(partitionStrategy: PartitionStrategy, numPartitions: Int): Graph[VD, ED] def partitionBy(partitionStrategy: PartitionStrategy, numPartitions: Int): Graph[VD, ED]
......
...@@ -182,8 +182,8 @@ class VertexRDD[@specialized VD: ClassTag]( ...@@ -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 * 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 * both VertexRDDs do not share the same index. The resulting vertex set contains an entry for
* each * each vertex in `this`.
* vertex in `this`. If `other` is missing any vertex in this VertexRDD, `f` is passed `None`. * If `other` is missing any vertex in this VertexRDD, `f` is passed `None`.
* *
* @tparam VD2 the attribute type of the other VertexRDD * @tparam VD2 the attribute type of the other VertexRDD
* @tparam VD3 the attribute type of the resulting VertexRDD * @tparam VD3 the attribute type of the resulting VertexRDD
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment