From 36a902e52d062ac352f95b317c308894496eecc2 Mon Sep 17 00:00:00 2001 From: Ankur Dave <ankurdave@gmail.com> Date: Fri, 18 Oct 2013 16:19:40 -0700 Subject: [PATCH] Revert accidental removal of code in 3a40a5e --- graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala | 1 + 1 file changed, 1 insertion(+) 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 a6604b978f..e7a708e895 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 @@ -275,6 +275,7 @@ class GraphImpl[VD: ClassManifest, ED: ClassManifest] protected ( .groupBy { t: EdgeTriplet[VD, ED] => (t.srcId, t.dstId) } .mapValues { ts: List[EdgeTriplet[VD, ED]] => f(ts.toIterator) } .toList + .toIterator .map { case ((src, dst), data) => Edge(src, dst, data) } } -- GitLab