diff options
| author | Ankur Dave <ankurdave@gmail.com> | 2013-12-14 03:21:17 -0800 |
|---|---|---|
| committer | Ankur Dave <ankurdave@gmail.com> | 2013-12-14 15:28:23 -0800 |
| commit | 9c8b6224ec58df8ba391363cadb5327d1dbf0872 (patch) | |
| tree | 8a106c03de0d9e3900bbedd6ecc564cec00cd8bb /graph/src/main | |
| parent | ef17ab58cbc7feaf6c381383b1759211569f7ec8 (diff) | |
| download | spark-9c8b6224ec58df8ba391363cadb5327d1dbf0872.tar.gz spark-9c8b6224ec58df8ba391363cadb5327d1dbf0872.tar.bz2 spark-9c8b6224ec58df8ba391363cadb5327d1dbf0872.zip | |
Remove unused bound variable
Diffstat (limited to 'graph/src/main')
| -rw-r--r-- | graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala b/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala index aeae378051..d15423e611 100644 --- a/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala +++ b/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala @@ -217,7 +217,8 @@ class GraphImpl[VD: ClassManifest, ED: ClassManifest] protected ( // Map and combine. val preAgg = edges.zipEdgePartitions(vs) { (edgePartition, vTableReplicatedIter) => - val (pid, vertexPartition) = vTableReplicatedIter.next() + val (_, vertexPartition) = vTableReplicatedIter.next() + // Iterate over the partition val et = new EdgeTriplet[VD, ED] val filteredEdges = edgePartition.iterator.flatMap { e => |