Author: edwardyoon
Date: Tue Jan 21 12:46:34 2014
New Revision: 1559998
URL: http://svn.apache.org/r1559998
Log:
Object reuse.
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=1559998&r1=1559997&r2=1559998&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
Tue Jan 21 12:46:34 2014
@@ -232,15 +232,16 @@ public final class GraphJobRunner<V exte
* currentMessage or the first vertex that is active.
*/
IDSkippingIterator<V, E, M> iterator = vertices.skippingIterator();
-
+ VertexMessageIterable<V, M> iterable = null;
+ Vertex<V, E, M> vertex = null;
+
// note that can't skip inactive vertices because we have to rewrite the
// complete vertex file in each iteration
while (iterator.hasNext(
currentMessage == null ? null : (V) currentMessage.getVertexId(),
Strategy.ALL)) {
- Vertex<V, E, M> vertex = iterator.next();
- VertexMessageIterable<V, M> iterable = null;
+ vertex = iterator.next();
if (currentMessage != null) {
iterable = iterate(currentMessage, (V) currentMessage.getVertexId(),
vertex, peer);