diff options
| author | Reynold Xin <rxin@databricks.com> | 2014-12-02 14:40:26 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2014-12-02 14:41:05 -0800 |
| commit | 2d4f6e70f7de50489c2b5f0d6a4756c3b1aace7d (patch) | |
| tree | 301d65759917da54d704ea3e16f42cf48cbca555 /graphx | |
| parent | 3ae0cda83c5106136e90d59c20e61db345a5085f (diff) | |
| download | spark-2d4f6e70f7de50489c2b5f0d6a4756c3b1aace7d.tar.gz spark-2d4f6e70f7de50489c2b5f0d6a4756c3b1aace7d.tar.bz2 spark-2d4f6e70f7de50489c2b5f0d6a4756c3b1aace7d.zip | |
Minor nit style cleanup in GraphX.
Diffstat (limited to 'graphx')
| -rw-r--r-- | graphx/src/main/scala/org/apache/spark/graphx/VertexRDD.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 1db3df03c8..09ae3f9f6c 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/VertexRDD.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/VertexRDD.scala @@ -68,7 +68,7 @@ abstract class VertexRDD[VD]( * Provides the `RDD[(VertexId, VD)]` equivalent output. */ override def compute(part: Partition, context: TaskContext): Iterator[(VertexId, VD)] = { - firstParent[ShippableVertexPartition[VD]].iterator(part, context).next.iterator + firstParent[ShippableVertexPartition[VD]].iterator(part, context).next().iterator } /** |