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 <[email protected]> Authored: Thu Dec 18 17:43:43 2014 -0800 Committer: Sergey Edunov <[email protected]> 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);
