tinkerpop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ok...@apache.org
Subject [11/15] incubator-tinkerpop git commit: minor nothing logic tweak.
Date Wed, 23 Mar 2016 13:09:20 GMT
minor nothing logic tweak.


Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/32afb58a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/32afb58a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/32afb58a

Branch: refs/heads/TINKERPOP-1231
Commit: 32afb58aead3cfeb61973b0c4748c691621ad91f
Parents: 20e9ed1
Author: Marko A. Rodriguez <okrammarko@gmail.com>
Authored: Tue Mar 22 10:21:22 2016 -0600
Committer: Marko A. Rodriguez <okrammarko@gmail.com>
Committed: Tue Mar 22 10:21:22 2016 -0600

----------------------------------------------------------------------
 .../process/computer/traversal/TraversalVertexProgram.java      | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/32afb58a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java
b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java
index 666a803..0cd873f 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java
@@ -144,8 +144,9 @@ public final class TraversalVertexProgram implements VertexProgram<TraverserSet<
         // if results will be serialized out, don't save halted traversers across the cluster
         this.keepDistributedHaltedTraversers =
                 !(this.traversal.get().getParent().asStep().getNextStep() instanceof ComputerResultStep
|| // if its just going to stream it out, don't distribute
-                        this.traversal.get().getParent().asStep().getNextStep().getNextStep()
instanceof ComputerResultStep ||
-                        this.traversal.get().getParent().asStep().getNextStep() instanceof
EmptyStep);  // same as above, but if using TraversalVertexProgramStep directly
+                        this.traversal.get().getParent().asStep().getNextStep() instanceof
EmptyStep ||  // same as above, but if using TraversalVertexProgramStep directly
+                        (this.traversal.get().getParent().asStep().getNextStep() instanceof
ProfileStep && // same as above, but needed for profiling
+                                this.traversal.get().getParent().asStep().getNextStep().getNextStep()
instanceof ComputerResultStep));
         // register traversal side-effects in memory
         final TraversalSideEffects sideEffects = ((MemoryTraversalSideEffects) this.traversal.get().getSideEffects()).getSideEffects();
         sideEffects.keys().forEach(key -> this.memoryComputeKeys.add(MemoryComputeKey.of(key,
sideEffects.getReducer(key), true, false)));


Mime
View raw message