You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by cl...@apache.org on 2013/04/11 22:05:17 UTC
[2/2] git commit: updated refs/heads/trunk to 67e0f11
GIRAPH-613
Project: http://git-wip-us.apache.org/repos/asf/giraph/repo
Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/67e0f11d
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/67e0f11d
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/67e0f11d
Branch: refs/heads/trunk
Commit: 67e0f11d2bd98e0614b26d4ea6dd707e6f65a105
Parents: 6cf79db
Author: Claudio Martella <cl...@apache.org>
Authored: Thu Apr 11 19:10:52 2013 +0200
Committer: Claudio Martella <cl...@apache.org>
Committed: Thu Apr 11 19:10:52 2013 +0200
----------------------------------------------------------------------
.../main/java/org/apache/giraph/graph/Vertex.java | 2 +-
.../giraph/partition/ByteArrayPartition.java | 4 ++++
2 files changed, 5 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/giraph/blob/67e0f11d/giraph-core/src/main/java/org/apache/giraph/graph/Vertex.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/graph/Vertex.java b/giraph-core/src/main/java/org/apache/giraph/graph/Vertex.java
index a1b1a87..ade25fe 100644
--- a/giraph-core/src/main/java/org/apache/giraph/graph/Vertex.java
+++ b/giraph-core/src/main/java/org/apache/giraph/graph/Vertex.java
@@ -40,7 +40,7 @@ import java.util.Iterator;
/**
* Basic abstract class for writing a BSP application for computation.
- * Giraph will checkpoint Vertex value and edges, hence all user data should
+ * Giraph will store Vertex value and edges, hence all user data should
* be stored as part of the vertex value.
*
* @param <I> Vertex id
http://git-wip-us.apache.org/repos/asf/giraph/blob/67e0f11d/giraph-core/src/main/java/org/apache/giraph/partition/ByteArrayPartition.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/partition/ByteArrayPartition.java b/giraph-core/src/main/java/org/apache/giraph/partition/ByteArrayPartition.java
index d2e7599..b7ec924 100644
--- a/giraph-core/src/main/java/org/apache/giraph/partition/ByteArrayPartition.java
+++ b/giraph-core/src/main/java/org/apache/giraph/partition/ByteArrayPartition.java
@@ -70,6 +70,10 @@ public class ByteArrayPartition<I extends WritableComparable,
vertexMap = new MapMaker().concurrencyLevel(
getConf().getNettyServerExecutionConcurrency()).makeMap();
representativeVertex = getConf().createVertex();
+ representativeVertex.initialize(
+ getConf().createVertexId(),
+ getConf().createVertexValue(),
+ getConf().createVertexEdges());
useUnsafeSerialization = getConf().useUnsafeSerialization();
}