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 2016/02/13 16:35:09 UTC
[15/17] incubator-tinkerpop git commit: forgot to put back the old
model after verifying something. changes nothing -- just simpler code.
forgot to put back the old model after verifying something. changes nothing -- just simpler code.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/0f4e737e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/0f4e737e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/0f4e737e
Branch: refs/heads/master
Commit: 0f4e737ef20d89d872f60698b1fca9af001e9ba7
Parents: d627f9c
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Fri Feb 12 15:52:55 2016 -0700
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Fri Feb 12 15:52:55 2016 -0700
----------------------------------------------------------------------
.../step/sideEffect/mapreduce/TraverserMapReduce.java | 10 +---------
1 file changed, 1 insertion(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/0f4e737e/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/step/sideEffect/mapreduce/TraverserMapReduce.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/step/sideEffect/mapreduce/TraverserMapReduce.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/step/sideEffect/mapreduce/TraverserMapReduce.java
index e68cd3f..a0245aa 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/step/sideEffect/mapreduce/TraverserMapReduce.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/step/sideEffect/mapreduce/TraverserMapReduce.java
@@ -51,8 +51,6 @@ import java.util.Optional;
*/
public final class TraverserMapReduce implements MapReduce<Comparable, Traverser<?>, Comparable, Traverser<?>, Iterator<Traverser<?>>> {
- public static final String TRAVERSER_TRAVERSAL = "gremlin.traverserMapReduce.traversal";
-
public static final String TRAVERSERS = Graph.Hidden.hide("traversers");
private Traversal.Admin<?, ?> traversal;
@@ -85,16 +83,10 @@ public final class TraverserMapReduce implements MapReduce<Comparable, Traverser
@Override
public void loadState(final Graph graph, final Configuration configuration) {
- this.traversal = VertexProgramHelper.deserialize(configuration, TRAVERSER_TRAVERSAL);
+ this.traversal = TraversalVertexProgram.getTraversal(graph, configuration);
this.genericLoadState();
}
- @Override
- public void storeState(final Configuration configuration) {
- MapReduce.super.storeState(configuration);
- VertexProgramHelper.serialize(this.traversal, configuration, TRAVERSER_TRAVERSAL);
- }
-
private void genericLoadState() {
final Step<?, ?> traversalEndStep = traversal.getEndStep();
if (traversalEndStep instanceof CollectingBarrierStep) {