hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tomm...@apache.org
Subject svn commit: r1502476 - /hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java
Date Fri, 12 Jul 2013 08:47:23 GMT
Author: tommaso
Date: Fri Jul 12 08:47:23 2013
New Revision: 1502476

URL: http://svn.apache.org/r1502476
Log:
HAMA-779 - make VerticesInfo implemantation configurable

Modified:
    hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java

Modified: hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java
URL: http://svn.apache.org/viewvc/hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java?rev=1502476&r1=1502475&r2=1502476&view=diff
==============================================================================
--- hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java (original)
+++ hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java Fri Jul 12 08:47:23
2013
@@ -356,8 +356,8 @@ public final class GraphJobRunner<V exte
     aggregationRunner = new AggregationRunner<V, E, M>();
     aggregationRunner.setupAggregators(peer);
 
-    // FIXME We should make this configurable.
-    vertices = new ListVerticesInfo();
+    Class<? extends VerticesInfo<V, E, M>> verticesInfoClass = (Class<? extends
VerticesInfo<V, E, M>>) conf.getClass("vertices.info", ListVerticesInfo.class, VerticesInfo.class);
+    vertices = ReflectionUtils.newInstance(verticesInfoClass);
     vertices.init(this, conf, peer.getTaskId());
   }
 



Mime
View raw message