Updated Branches: refs/heads/trunk 67e0f11d2 -> ff8d98e20
GIRAPH-613 Project: http://git-wip-us.apache.org/repos/asf/giraph/repo Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/ff8d98e2 Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/ff8d98e2 Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/ff8d98e2 Branch: refs/heads/trunk Commit: ff8d98e20a4b2475f5890ade5ee78dc8d804420c Parents: 67e0f11 Author: Claudio Martella <[email protected]> Authored: Thu Apr 11 22:06:25 2013 +0200 Committer: Claudio Martella <[email protected]> Committed: Thu Apr 11 22:06:25 2013 +0200 ---------------------------------------------------------------------- .../giraph/partition/ByteArrayPartition.java | 4 ++++ .../org/apache/giraph/utils/WritableUtils.java | 4 +--- 2 files changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/giraph/blob/ff8d98e2/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 b7ec924..7c7fc2b 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 @@ -191,6 +191,10 @@ public class ByteArrayPartition<I extends WritableComparable, getConf().getNettyServerExecutionConcurrency()).initialCapacity( size).makeMap(); representativeVertex = getConf().createVertex(); + representativeVertex.initialize( + getConf().createVertexId(), + getConf().createVertexValue(), + getConf().createVertexEdges()); useUnsafeSerialization = getConf().useUnsafeSerialization(); for (int i = 0; i < size; ++i) { progress(); http://git-wip-us.apache.org/repos/asf/giraph/blob/ff8d98e2/giraph-core/src/main/java/org/apache/giraph/utils/WritableUtils.java ---------------------------------------------------------------------- diff --git a/giraph-core/src/main/java/org/apache/giraph/utils/WritableUtils.java b/giraph-core/src/main/java/org/apache/giraph/utils/WritableUtils.java index e3d79f7..5391aa0 100644 --- a/giraph-core/src/main/java/org/apache/giraph/utils/WritableUtils.java +++ b/giraph-core/src/main/java/org/apache/giraph/utils/WritableUtils.java @@ -402,10 +402,9 @@ public class WritableUtils { * @param <E> Edge value * @param <M> Message value * @param conf Configuration - * @return The vertex */ public static <I extends WritableComparable, V extends Writable, - E extends Writable, M extends Writable> Vertex<I, V, E, M> + E extends Writable, M extends Writable> void reinitializeVertexFromByteArray( byte[] byteArray, Vertex<I, V, E, M> vertex, @@ -424,7 +423,6 @@ public class WritableUtils { throw new IllegalStateException( "readFieldsFromByteArrayWithSize: IOException", e); } - return vertex; } /**
