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/06 20:54:43 UTC
[12/30] incubator-tinkerpop git commit: Forgot to add vertices() and
edges() to the ComputerTraversalEngine.Builder. I can't wait for this model
to go away in favor of a fluent TraversalSource.
Forgot to add vertices() and edges() to the ComputerTraversalEngine.Builder. I can't wait for this model to go away in favor of a fluent TraversalSource.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/7023987a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/7023987a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/7023987a
Branch: refs/heads/master
Commit: 7023987a0b5154646a4d77e0b2b3506e850ed3d2
Parents: e4cf925
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Tue Feb 2 13:35:27 2016 -0700
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Tue Feb 2 13:35:27 2016 -0700
----------------------------------------------------------------------
.../engine/ComputerTraversalEngine.java | 23 +++++++++++++++++---
1 file changed, 20 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/7023987a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/engine/ComputerTraversalEngine.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/engine/ComputerTraversalEngine.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/engine/ComputerTraversalEngine.java
index 8461791..3928bf9 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/engine/ComputerTraversalEngine.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/engine/ComputerTraversalEngine.java
@@ -26,7 +26,9 @@ import org.apache.tinkerpop.gremlin.process.traversal.TraversalStrategy;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.EmptyStep;
import org.apache.tinkerpop.gremlin.process.traversal.strategy.AbstractTraversalStrategy;
import org.apache.tinkerpop.gremlin.process.traversal.strategy.finalization.ProfileStrategy;
+import org.apache.tinkerpop.gremlin.structure.Edge;
import org.apache.tinkerpop.gremlin.structure.Graph;
+import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.apache.tinkerpop.gremlin.structure.util.StringFactory;
import java.util.Collections;
@@ -70,7 +72,8 @@ public final class ComputerTraversalEngine implements TraversalEngine {
private Class<? extends GraphComputer> graphComputerClass;
private int workers = -1;
private static final List<TraversalStrategy> WITH_STRATEGIES = Collections.singletonList(ComputerResultStrategy.instance());
-
+ private Traversal<Vertex, Vertex> vertexFilter = null;
+ private Traversal<Vertex, Edge> edgeFilter = null;
@Override
public List<TraversalStrategy> getWithStrategies() {
@@ -87,11 +90,25 @@ public final class ComputerTraversalEngine implements TraversalEngine {
return this;
}
+ public Builder vertices(final Traversal<Vertex, Vertex> vertexFilter) {
+ this.vertexFilter = vertexFilter;
+ return this;
+ }
+
+ public Builder edges(final Traversal<Vertex, Edge> edgeFilter) {
+ this.edgeFilter = edgeFilter;
+ return this;
+ }
+
public ComputerTraversalEngine create(final Graph graph) {
- final GraphComputer graphComputer = null == this.graphComputerClass ? graph.compute() : graph.compute(this.graphComputerClass);
+ GraphComputer graphComputer = null == this.graphComputerClass ? graph.compute() : graph.compute(this.graphComputerClass);
if (-1 != this.workers)
- graphComputer.workers(this.workers);
+ graphComputer = graphComputer.workers(this.workers);
+ if (null != this.vertexFilter)
+ graphComputer = graphComputer.vertices(this.vertexFilter);
+ if (null != this.edgeFilter)
+ graphComputer = graphComputer.edges(this.edgeFilter);
return new ComputerTraversalEngine(graphComputer);
}
}