You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by to...@apache.org on 2013/07/12 10:47:23 UTC
svn commit: r1502476 -
/hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java
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());
}