giraph-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edu...@apache.org
Subject git commit: updated refs/heads/trunk to 480475a
Date Fri, 19 Dec 2014 01:56:14 GMT
Repository: giraph
Updated Branches:
  refs/heads/trunk 7f2d58445 -> 480475a51


GIRAPH-973 Edge trimming no longer works before superstep 0


Project: http://git-wip-us.apache.org/repos/asf/giraph/repo
Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/480475a5
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/480475a5
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/480475a5

Branch: refs/heads/trunk
Commit: 480475a51776bfb20d9515978b7803ca14b0dd05
Parents: 7f2d584
Author: Sergey Edunov <edunov@fb.com>
Authored: Thu Dec 18 17:43:43 2014 -0800
Committer: Sergey Edunov <edunov@fb.com>
Committed: Thu Dec 18 17:43:43 2014 -0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/giraph/edge/AbstractEdgeStore.java  | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/giraph/blob/480475a5/giraph-core/src/main/java/org/apache/giraph/edge/AbstractEdgeStore.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/edge/AbstractEdgeStore.java b/giraph-core/src/main/java/org/apache/giraph/edge/AbstractEdgeStore.java
index dc7a5b4..5d15707 100644
--- a/giraph-core/src/main/java/org/apache/giraph/edge/AbstractEdgeStore.java
+++ b/giraph-core/src/main/java/org/apache/giraph/edge/AbstractEdgeStore.java
@@ -26,6 +26,7 @@ import org.apache.giraph.graph.Vertex;
 import org.apache.giraph.partition.Partition;
 import org.apache.giraph.utils.CallableFactory;
 import org.apache.giraph.utils.ProgressableUtils;
+import org.apache.giraph.utils.Trimmable;
 import org.apache.giraph.utils.VertexIdEdgeIterator;
 import org.apache.giraph.utils.VertexIdEdges;
 import org.apache.hadoop.io.Writable;
@@ -245,6 +246,9 @@ public abstract class AbstractEdgeStore<I extends WritableComparable,
                       vertex.addEdge(edge);
                     }
                   }
+                  if (vertex instanceof Trimmable) {
+                    ((Trimmable) vertex).trim();
+                  }
                   // Some Partition implementations (e.g. ByteArrayPartition)
                   // require us to put back the vertex after modifying it.
                   partition.saveVertex(vertex);


Mime
View raw message