You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by ma...@apache.org on 2013/03/12 05:22:42 UTC

git commit: GIRAPH-554: Set PartitionContext in InternalVertexRunner (majakabiljo)

Updated Branches:
  refs/heads/trunk 799824014 -> ea831c80b


GIRAPH-554: Set PartitionContext in InternalVertexRunner (majakabiljo)


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

Branch: refs/heads/trunk
Commit: ea831c80b8cfd33a233a34666537f840f2c104bf
Parents: 7998240
Author: Maja Kabiljo <ma...@maja-mbp.thefacebook.com>
Authored: Mon Mar 11 21:21:58 2013 -0700
Committer: Maja Kabiljo <ma...@maja-mbp.thefacebook.com>
Committed: Mon Mar 11 21:21:58 2013 -0700

----------------------------------------------------------------------
 CHANGELOG                                          |    2 ++
 .../apache/giraph/utils/InternalVertexRunner.java  |    3 +++
 2 files changed, 5 insertions(+), 0 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/giraph/blob/ea831c80/CHANGELOG
----------------------------------------------------------------------
diff --git a/CHANGELOG b/CHANGELOG
index 90d626f..9ca3b3b 100644
--- a/CHANGELOG
+++ b/CHANGELOG
@@ -1,6 +1,8 @@
 Giraph Change Log
 
 Release 0.2.0 - unreleased
+  GIRAPH-554: Set PartitionContext in InternalVertexRunner (majakabiljo)
+
   GIRAPH-559: Giraph build breaks (nitay)
 
   GIRAPH-550: HiveVertexReader should call initialize, not users (nitay)

http://git-wip-us.apache.org/repos/asf/giraph/blob/ea831c80/giraph-core/src/main/java/org/apache/giraph/utils/InternalVertexRunner.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/utils/InternalVertexRunner.java b/giraph-core/src/main/java/org/apache/giraph/utils/InternalVertexRunner.java
index 7848d1c..7989483 100644
--- a/giraph-core/src/main/java/org/apache/giraph/utils/InternalVertexRunner.java
+++ b/giraph-core/src/main/java/org/apache/giraph/utils/InternalVertexRunner.java
@@ -138,6 +138,9 @@ public class InternalVertexRunner {
       if (classes.hasWorkerContextClass()) {
         conf.setWorkerContextClass(classes.getWorkerContextClass());
       }
+      if (classes.hasPartitionContextClass()) {
+        conf.setMasterComputeClass(classes.getPartitionContextClass());
+      }
       if (classes.hasCombinerClass()) {
         conf.setVertexCombinerClass(classes.getCombinerClass());
       }