You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by ok...@apache.org on 2015/02/18 23:30:28 UTC
[2/5] incubator-tinkerpop git commit: DefaultMapReduce 'just works.'
DefaultMapReduce 'just works.'
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/a949e612
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/a949e612
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/a949e612
Branch: refs/heads/master
Commit: a949e6125907742bc80830ca475423bf1adcf1d3
Parents: 2b949ae
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Wed Feb 18 14:44:20 2015 -0700
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Wed Feb 18 14:44:20 2015 -0700
----------------------------------------------------------------------
.../process/graph/traversal/step/util/ReducingBarrierStep.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/a949e612/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/graph/traversal/step/util/ReducingBarrierStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/graph/traversal/step/util/ReducingBarrierStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/graph/traversal/step/util/ReducingBarrierStep.java
index 0a3f10f..9e1ab48 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/graph/traversal/step/util/ReducingBarrierStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/graph/traversal/step/util/ReducingBarrierStep.java
@@ -33,6 +33,7 @@ import org.apache.tinkerpop.gremlin.process.traversal.util.TraversalHelper;
import org.apache.tinkerpop.gremlin.process.util.TraverserSet;
import org.apache.tinkerpop.gremlin.structure.Graph;
import org.apache.tinkerpop.gremlin.structure.Vertex;
+import org.apache.tinkerpop.gremlin.util.iterator.IteratorUtils;
import java.io.Serializable;
import java.util.Iterator;
@@ -143,7 +144,7 @@ public abstract class ReducingBarrierStep<S, E> extends AbstractStep<S, E> imple
@Override
public Object generateFinalResult(final Iterator keyValues) {
- return ((KeyValue) keyValues.next()).getValue();
+ return IteratorUtils.of(((KeyValue) keyValues.next()).getValue());
}