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/19 17:51:59 UTC
incubator-tinkerpop git commit: connected MapReduce to
MeanGlobalStep. fixed a type casting error in map().
Repository: incubator-tinkerpop
Updated Branches:
refs/heads/master 2286ce4f6 -> 1f1305447
connected MapReduce to MeanGlobalStep. fixed a type casting error in map().
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/1f130544
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/1f130544
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/1f130544
Branch: refs/heads/master
Commit: 1f13054471c52d006d3cec72697366de6968bf93
Parents: 2286ce4
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Thu Feb 19 09:51:48 2015 -0700
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Thu Feb 19 09:51:57 2015 -0700
----------------------------------------------------------------------
.../process/graph/traversal/step/map/MeanGlobalStep.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/1f130544/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/graph/traversal/step/map/MeanGlobalStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/graph/traversal/step/map/MeanGlobalStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/graph/traversal/step/map/MeanGlobalStep.java
index 887bd51..94c43f5 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/graph/traversal/step/map/MeanGlobalStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/graph/traversal/step/map/MeanGlobalStep.java
@@ -56,6 +56,11 @@ public final class MeanGlobalStep<S extends Number, E extends Number> extends Re
return REQUIREMENTS;
}
+ @Override
+ public MapReduce<MapReduce.NullObject, MeanNumber, MapReduce.NullObject, MeanNumber, Double> getMapReduce() {
+ return MeanMapReduce.instance();
+ }
+
/////
private static class MeanBiFunction<S extends Number> implements BiFunction<S, Traverser<S>, S>, Serializable {
@@ -93,7 +98,7 @@ public final class MeanGlobalStep<S extends Number, E extends Number> extends Re
@Override
public void map(final Vertex vertex, final MapEmitter<NullObject, MeanNumber> emitter) {
- vertex.<TraverserSet<MeanNumber>>property(TraversalVertexProgram.HALTED_TRAVERSERS).ifPresent(traverserSet -> traverserSet.forEach(traverser -> emitter.emit(new MeanNumber(traverser.get().doubleValue(), traverser.bulk()))));
+ vertex.<TraverserSet<Number>>property(TraversalVertexProgram.HALTED_TRAVERSERS).ifPresent(traverserSet -> traverserSet.forEach(traverser -> emitter.emit(new MeanNumber(traverser.get().doubleValue(), traverser.bulk()))));
}
@Override