svn commit: r1502476 - /hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java

[tommaso]

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());
   }