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/08/26 19:03:30 UTC
[1/8] incubator-tinkerpop git commit: first push on mutating steps
with traversal parameterization.
Repository: incubator-tinkerpop
Updated Branches:
refs/heads/master 95ff755d6 -> 8d975818d
first push on mutating steps with traversal parameterization.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/6ffcca3c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/6ffcca3c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/6ffcca3c
Branch: refs/heads/master
Commit: 6ffcca3cd91a3d3607497783e06c4c4aaa7e48f2
Parents: ae64495
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Tue Aug 25 12:19:32 2015 -0600
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Tue Aug 25 12:19:32 2015 -0600
----------------------------------------------------------------------
.../traversal/dsl/graph/GraphTraversal.java | 168 +++++++++++++++++--
.../dsl/graph/GraphTraversalSource.java | 35 +++-
.../gremlin/process/traversal/dsl/graph/__.java | 39 ++++-
.../process/traversal/step/Mutating.java | 5 +
.../traversal/step/map/AddVertexStartStep.java | 23 ++-
.../traversal/step/map/AddVertexStep.java | 50 ++++--
.../step/sideEffect/AddPropertyStep.java | 80 ++++-----
.../process/traversal/step/util/Parameters.java | 96 +++++++++++
.../strategy/decoration/ElementIdStrategy.java | 17 +-
.../strategy/decoration/PartitionStrategy.java | 4 +-
.../strategy/decoration/EventStrategyTest.java | 2 +-
.../verification/ReadOnlyStrategyTest.java | 2 +-
.../step/map/GroovyAddVertexTest.groovy | 24 ++-
.../traversal/step/map/AddVertexTest.java | 77 ++++++++-
.../ElementIdStrategyProcessTest.java | 25 +--
.../decoration/EventStrategyProcessTest.java | 24 +--
.../PartitionStrategyProcessTest.java | 22 +--
.../tinkergraph/structure/TinkerGraphTest.java | 5 +-
18 files changed, 561 insertions(+), 137 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
index a643e48..043882c 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
@@ -18,22 +18,140 @@
*/
package org.apache.tinkerpop.gremlin.process.traversal.dsl.graph;
-import org.apache.tinkerpop.gremlin.process.traversal.*;
-import org.apache.tinkerpop.gremlin.process.traversal.lambda.*;
+import org.apache.tinkerpop.gremlin.process.traversal.Order;
+import org.apache.tinkerpop.gremlin.process.traversal.P;
+import org.apache.tinkerpop.gremlin.process.traversal.Path;
+import org.apache.tinkerpop.gremlin.process.traversal.Pop;
+import org.apache.tinkerpop.gremlin.process.traversal.Scope;
+import org.apache.tinkerpop.gremlin.process.traversal.Step;
+import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
+import org.apache.tinkerpop.gremlin.process.traversal.Traverser;
+import org.apache.tinkerpop.gremlin.process.traversal.lambda.ElementValueTraversal;
+import org.apache.tinkerpop.gremlin.process.traversal.lambda.FunctionTraverser;
+import org.apache.tinkerpop.gremlin.process.traversal.lambda.IdentityTraversal;
+import org.apache.tinkerpop.gremlin.process.traversal.lambda.LoopTraversal;
+import org.apache.tinkerpop.gremlin.process.traversal.lambda.PredicateTraverser;
+import org.apache.tinkerpop.gremlin.process.traversal.lambda.TokenTraversal;
+import org.apache.tinkerpop.gremlin.process.traversal.lambda.TrueTraversal;
import org.apache.tinkerpop.gremlin.process.traversal.step.ComparatorHolder;
+import org.apache.tinkerpop.gremlin.process.traversal.step.Mutating;
import org.apache.tinkerpop.gremlin.process.traversal.step.TraversalOptionParent;
import org.apache.tinkerpop.gremlin.process.traversal.step.TraversalParent;
-import org.apache.tinkerpop.gremlin.process.traversal.step.branch.*;
-import org.apache.tinkerpop.gremlin.process.traversal.step.filter.*;
-import org.apache.tinkerpop.gremlin.process.traversal.step.map.*;
-import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.*;
-import org.apache.tinkerpop.gremlin.process.traversal.step.util.*;
+import org.apache.tinkerpop.gremlin.process.traversal.step.branch.BranchStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.branch.ChooseStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.branch.LocalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.branch.RepeatStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.branch.UnionStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.AndStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.CoinStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.ConjunctionStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.CyclicPathStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.DedupGlobalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.DropStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.HasStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.IsStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.LambdaFilterStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.NotStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.OrStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.RangeGlobalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.SampleGlobalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.SimplePathStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.TailGlobalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.TimeLimitStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.TraversalFilterStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.WherePredicateStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.filter.WhereTraversalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.AddEdgeStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.AddVertexStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.CoalesceStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.ConstantStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.CountGlobalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.CountLocalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.DedupLocalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.EdgeOtherVertexStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.EdgeVertexStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.FoldStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.GroupCountStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.GroupStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.IdStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.LabelStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.LambdaFlatMapStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.LambdaMapStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.LoopsStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.MapKeysStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.MapValuesStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.MatchStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.MaxGlobalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.MaxLocalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.MeanGlobalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.MeanLocalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.MinGlobalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.MinLocalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.OrderGlobalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.OrderLocalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.PathStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.PropertiesStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.PropertyKeyStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.PropertyMapStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.PropertyValueStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.RangeLocalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.SackStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.SampleLocalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.SelectOneStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.SelectStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.SumGlobalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.SumLocalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.TailLocalStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.TraversalFlatMapStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.TraversalMapStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.TreeStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.UnfoldStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.VertexStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.AddPropertyStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.AggregateStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.GroupCountSideEffectStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.GroupSideEffectStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.IdentityStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.InjectStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.LambdaSideEffectStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.ProfileStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.SackElementValueStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.SackObjectStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.SideEffectCapStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.StartStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.StoreStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.SubgraphStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.TraversalSideEffectStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.TreeSideEffectStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.util.ElementFunctionComparator;
+import org.apache.tinkerpop.gremlin.process.traversal.step.util.ElementValueComparator;
+import org.apache.tinkerpop.gremlin.process.traversal.step.util.HasContainer;
+import org.apache.tinkerpop.gremlin.process.traversal.step.util.NoOpBarrierStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.util.TraversalComparator;
+import org.apache.tinkerpop.gremlin.process.traversal.step.util.Tree;
import org.apache.tinkerpop.gremlin.process.traversal.util.TraversalHelper;
-import org.apache.tinkerpop.gremlin.structure.*;
+import org.apache.tinkerpop.gremlin.structure.Direction;
+import org.apache.tinkerpop.gremlin.structure.Edge;
+import org.apache.tinkerpop.gremlin.structure.Element;
+import org.apache.tinkerpop.gremlin.structure.Property;
+import org.apache.tinkerpop.gremlin.structure.PropertyType;
+import org.apache.tinkerpop.gremlin.structure.T;
+import org.apache.tinkerpop.gremlin.structure.Vertex;
+import org.apache.tinkerpop.gremlin.structure.VertexProperty;
+import org.apache.tinkerpop.gremlin.structure.util.ElementHelper;
import org.apache.tinkerpop.gremlin.util.function.ConstantSupplier;
-import java.util.*;
-import java.util.function.*;
+import java.util.Arrays;
+import java.util.Comparator;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.function.BiFunction;
+import java.util.function.BinaryOperator;
+import java.util.function.Consumer;
+import java.util.function.Function;
+import java.util.function.Predicate;
/**
* @author Marko A. Rodriguez (http://markorodriguez.com)
@@ -519,8 +637,19 @@ public interface GraphTraversal<S, E> extends Traversal<S, E> {
return this.asAdmin().addStep(new TreeStep<>(this.asAdmin()));
}
- public default GraphTraversal<S, Vertex> addV(final Object... keyValues) {
- return this.asAdmin().addStep(new AddVertexStep<>(this.asAdmin(), keyValues));
+ public default GraphTraversal<S, Vertex> addV(final String vertexLabel) {
+ return this.asAdmin().addStep(new AddVertexStep<>(this.asAdmin(), vertexLabel));
+ }
+
+ public default GraphTraversal<S, Vertex> addV() {
+ return this.asAdmin().addStep(new AddVertexStep<>(this.asAdmin(), null));
+ }
+
+ @Deprecated
+ public default GraphTraversal<S, Vertex> addV(final Object... propertyKeyValues) {
+ this.addV(ElementHelper.getLabelValue(propertyKeyValues).orElse(Vertex.DEFAULT_LABEL));
+ ((AddVertexStep) this.asAdmin().getEndStep()).addPropertyMutations(propertyKeyValues);
+ return (GraphTraversal<S, Vertex>) this;
}
public default GraphTraversal<S, Edge> addE(final Direction direction, final String firstVertexKeyOrEdgeLabel, final String edgeLabelOrSecondVertexKey, final Object... propertyKeyValues) {
@@ -803,12 +932,19 @@ public interface GraphTraversal<S, E> extends Traversal<S, E> {
return this.asAdmin().addStep(new ProfileStep<>(this.asAdmin()));
}
- public default GraphTraversal<S, E> property(final String key, final Object value, final Object... keyValues) {
- return this.asAdmin().addStep(new AddPropertyStep(this.asAdmin(), key, value, keyValues));
+
+ public default GraphTraversal<S, E> property(final VertexProperty.Cardinality cardinality, final Object key, final Object value, final Object... keyValues) {
+ if ((this.asAdmin().getEndStep() instanceof AddVertexStep || this.asAdmin().getEndStep() instanceof AddEdgeStep) && keyValues.length == 0) {
+ ((Mutating) this.asAdmin().getEndStep()).addPropertyMutations(new Object[]{key, value});
+ } else {
+ this.asAdmin().addStep(new AddPropertyStep(this.asAdmin(), cardinality, key, value));
+ ((AddPropertyStep) this.asAdmin().getEndStep()).addPropertyMutations(keyValues);
+ }
+ return this;
}
- public default GraphTraversal<S, E> property(final VertexProperty.Cardinality cardinality, final String key, final Object value, final Object... keyValues) {
- return this.asAdmin().addStep(new AddPropertyStep(this.asAdmin(), cardinality, key, value, keyValues));
+ public default GraphTraversal<S, E> property(final Object key, final Object value, final Object... keyValues) {
+ return this.property(null, key, value, keyValues);
}
///////////////////// BRANCH STEPS /////////////////////
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalSource.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalSource.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalSource.java
index 59b9b18..799aca3 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalSource.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalSource.java
@@ -90,9 +90,25 @@ public class GraphTraversalSource implements TraversalSource {
return traversal;
}
+ /**
+ * @deprecated As of release 3.1.0, replaced by {@link #addV()}
+ */
+ @Deprecated
public GraphTraversal<Vertex, Vertex> addV(final Object... keyValues) {
final GraphTraversal.Admin<Vertex, Vertex> traversal = this.generateTraversal();
- return traversal.addStep(new AddVertexStartStep(traversal, keyValues));
+ traversal.addStep(new AddVertexStartStep(traversal, null));
+ ((AddVertexStartStep) traversal.getEndStep()).addPropertyMutations(keyValues);
+ return traversal;
+ }
+
+ public GraphTraversal<Vertex, Vertex> addV(final String label) {
+ final GraphTraversal.Admin<Vertex, Vertex> traversal = this.generateTraversal();
+ return traversal.addStep(new AddVertexStartStep(traversal, label));
+ }
+
+ public GraphTraversal<Vertex, Vertex> addV() {
+ final GraphTraversal.Admin<Vertex, Vertex> traversal = this.generateTraversal();
+ return traversal.addStep(new AddVertexStartStep(traversal, null));
}
public GraphTraversal<Vertex, Vertex> V(final Object... vertexIds) {
@@ -228,8 +244,23 @@ public class GraphTraversalSource implements TraversalSource {
this.withPaths = withPaths;
}
+ /**
+ * @deprecated As of release 3.1.0, replaced by {@link #addV()}
+ */
+ @Deprecated
public GraphTraversal<Vertex, Vertex> addV(final Object... keyValues) {
- this.traversal.addStep(new AddVertexStartStep(this.traversal, keyValues));
+ this.traversal.addStep(new AddVertexStartStep(this.traversal, null));
+ ((AddVertexStartStep) this.traversal.getEndStep()).addPropertyMutations(keyValues);
+ return ((this.withPaths) ? this.traversal.addStep(new PathIdentityStep<>(this.traversal)) : this.traversal);
+ }
+
+ public GraphTraversal<Vertex, Vertex> addV(final String label) {
+ this.traversal.addStep(new AddVertexStartStep(this.traversal, label));
+ return ((this.withPaths) ? this.traversal.addStep(new PathIdentityStep<>(this.traversal)) : this.traversal);
+ }
+
+ public GraphTraversal<Vertex, Vertex> addV() {
+ this.traversal.addStep(new AddVertexStartStep(this.traversal, null));
return ((this.withPaths) ? this.traversal.addStep(new PathIdentityStep<>(this.traversal)) : this.traversal);
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/__.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/__.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/__.java
index e2d9e80..b20e4a9 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/__.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/__.java
@@ -18,14 +18,28 @@
*/
package org.apache.tinkerpop.gremlin.process.traversal.dsl.graph;
-import org.apache.tinkerpop.gremlin.process.traversal.*;
+import org.apache.tinkerpop.gremlin.process.traversal.P;
+import org.apache.tinkerpop.gremlin.process.traversal.Path;
+import org.apache.tinkerpop.gremlin.process.traversal.Pop;
+import org.apache.tinkerpop.gremlin.process.traversal.Scope;
+import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
+import org.apache.tinkerpop.gremlin.process.traversal.Traverser;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.Tree;
-import org.apache.tinkerpop.gremlin.structure.*;
+import org.apache.tinkerpop.gremlin.structure.Direction;
+import org.apache.tinkerpop.gremlin.structure.Edge;
+import org.apache.tinkerpop.gremlin.structure.Property;
+import org.apache.tinkerpop.gremlin.structure.T;
+import org.apache.tinkerpop.gremlin.structure.Vertex;
+import org.apache.tinkerpop.gremlin.structure.VertexProperty;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
-import java.util.function.*;
+import java.util.function.BiFunction;
+import java.util.function.BinaryOperator;
+import java.util.function.Consumer;
+import java.util.function.Function;
+import java.util.function.Predicate;
/**
* @author Marko A. Rodriguez (http://markorodriguez.com)
@@ -434,8 +448,23 @@ public class __ {
}
/**
+ * @see {@link GraphTraversal#addV(String)}
+ */
+ public static <A> GraphTraversal<A, Vertex> addV(final String vertexLabel) {
+ return __.<A>start().addV(vertexLabel);
+ }
+
+ /**
+ * @see {@link GraphTraversal#addV()}
+ */
+ public static <A> GraphTraversal<A, Vertex> addV() {
+ return __.<A>start().addV();
+ }
+
+ /**
* @see {@link GraphTraversal#addV(Object...)}
*/
+ @Deprecated
public static <A> GraphTraversal<A, Vertex> addV(final Object... propertyKeyValues) {
return __.<A>start().addV(propertyKeyValues);
}
@@ -673,11 +702,11 @@ public class __ {
return __.<A>start().store(sideEffectKey);
}
- public static <A> GraphTraversal<A, A> property(final String key, final Object value, final Object... keyValues) {
+ public static <A> GraphTraversal<A, A> property(final Object key, final Object value, final Object... keyValues) {
return __.<A>start().property(key, value, keyValues);
}
- public static <A> GraphTraversal<A, A> property(final VertexProperty.Cardinality cardinality, final String key, final Object value, final Object... keyValues) {
+ public static <A> GraphTraversal<A, A> property(final VertexProperty.Cardinality cardinality, final Object key, final Object value, final Object... keyValues) {
return __.<A>start().property(cardinality, key, value, keyValues);
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/Mutating.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/Mutating.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/Mutating.java
index 07bb350..17d8e09 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/Mutating.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/Mutating.java
@@ -34,4 +34,9 @@ public interface Mutating<E extends Event> {
* Gets the callback registry for events that the step raises.
*/
public CallbackRegistry<E> getMutatingCallbackRegistry();
+
+ public default void addPropertyMutations(final Object... keyValues) {
+
+ }
+
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java
index 3702aa0..e63fd8c 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java
@@ -26,33 +26,46 @@ import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.CallbackRe
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.Event;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.ListCallbackRegistry;
import org.apache.tinkerpop.gremlin.process.traversal.util.FastNoSuchElementException;
+import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.apache.tinkerpop.gremlin.structure.util.detached.DetachedFactory;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
/**
* @author Marko A. Rodriguez (http://markorodriguez.com)
* @author Stephen Mallette (http://stephen.genoprime.com)
*/
public final class AddVertexStartStep extends AbstractStep<Vertex, Vertex> implements Mutating<Event.VertexAddedEvent> {
- private final Object[] keyValues;
+ private List<Object> keyValues = new ArrayList<>();
private boolean first = true;
private CallbackRegistry<Event.VertexAddedEvent> callbackRegistry;
- public AddVertexStartStep(final Traversal.Admin traversal, final Object... keyValues) {
+ public AddVertexStartStep(final Traversal.Admin traversal, final String label) {
super(traversal);
- this.keyValues = keyValues;
+ if (null != label) {
+ this.keyValues.add(T.label);
+ this.keyValues.add(label);
+ }
}
public Object[] getKeyValues() {
- return keyValues;
+ return keyValues.toArray(new Object[this.keyValues.size()]);
+ }
+
+ @Override
+ public void addPropertyMutations(final Object... keyValues) {
+ Collections.addAll(this.keyValues, keyValues);
}
@Override
protected Traverser<Vertex> processNextStart() {
if (this.first) {
this.first = false;
- final Vertex v = this.getTraversal().getGraph().get().addVertex(this.keyValues);
+ final Vertex v = this.getTraversal().getGraph().get().addVertex(this.keyValues.toArray(new Object[this.keyValues.size()]));
if (callbackRegistry != null) {
final Event.VertexAddedEvent vae = new Event.VertexAddedEvent(DetachedFactory.detach(v, true));
callbackRegistry.getCallbacks().forEach(c -> c.accept(vae));
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java
index dbf88b5..77c4786 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java
@@ -21,35 +21,56 @@ package org.apache.tinkerpop.gremlin.process.traversal.step.map;
import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
import org.apache.tinkerpop.gremlin.process.traversal.Traverser;
import org.apache.tinkerpop.gremlin.process.traversal.step.Mutating;
+import org.apache.tinkerpop.gremlin.process.traversal.step.TraversalParent;
+import org.apache.tinkerpop.gremlin.process.traversal.step.util.Parameters;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.CallbackRegistry;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.Event;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.ListCallbackRegistry;
-import org.apache.tinkerpop.gremlin.structure.Graph;
+import org.apache.tinkerpop.gremlin.process.traversal.traverser.TraverserRequirement;
+import org.apache.tinkerpop.gremlin.process.traversal.traverser.util.EmptyTraverser;
+import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.apache.tinkerpop.gremlin.structure.util.detached.DetachedFactory;
+import java.util.List;
+import java.util.Set;
+
/**
* @author Marko A. Rodriguez (http://markorodriguez.com)
* @author Stephen Mallette (http://stephen.genoprime.com)
*/
-public final class AddVertexStep<S> extends MapStep<S, Vertex> implements Mutating<Event.VertexAddedEvent> {
-
- private final Object[] keyValues;
+public final class AddVertexStep<S> extends MapStep<S, Vertex> implements Mutating<Event.VertexAddedEvent>, TraversalParent {
+ private final Parameters parameters = new Parameters();
private CallbackRegistry<Event.VertexAddedEvent> callbackRegistry;
- public AddVertexStep(final Traversal.Admin traversal, final Object... keyValues) {
+ public AddVertexStep(final Traversal.Admin traversal, final String label) {
super(traversal);
- this.keyValues = keyValues;
+ this.parameters.set(T.label, label);
+ this.parameters.integrateTraversals(this);
+ }
+
+ @Override
+ public <S, E> List<Traversal.Admin<S, E>> getLocalChildren() {
+ return this.parameters.getTraversals();
}
+
public Object[] getKeyValues() {
- return keyValues;
+ return this.parameters.getKeyValues(EmptyTraverser.instance());
+ }
+
+ @Override
+ public void addPropertyMutations(final Object... keyValues) {
+ for (int i = 0; i < keyValues.length; i = i + 2) {
+ this.parameters.set(keyValues[i], keyValues[i + 1]);
+ }
+ this.parameters.integrateTraversals(this);
}
@Override
protected Vertex map(final Traverser.Admin<S> traverser) {
- final Vertex v = this.getTraversal().getGraph().get().addVertex(this.keyValues);
+ final Vertex v = this.getTraversal().getGraph().get().addVertex(this.parameters.getKeyValues(traverser));
if (callbackRegistry != null) {
final Event.VertexAddedEvent vae = new Event.VertexAddedEvent(DetachedFactory.detach(v, true));
callbackRegistry.getCallbacks().forEach(c -> c.accept(vae));
@@ -65,10 +86,13 @@ public final class AddVertexStep<S> extends MapStep<S, Vertex> implements Mutati
@Override
public int hashCode() {
- int result = super.hashCode(), i = 0;
- for (final Object item : this.keyValues) {
- result ^= Integer.rotateLeft(item.hashCode(), i += 16);
- }
- return result;
+ return super.hashCode() ^ this.parameters.hashCode();
}
+
+ @Override
+ public Set<TraverserRequirement> getRequirements() {
+ return this.getSelfAndChildRequirements();
+ }
+
+ // TODO clone()
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
index b2b0c1a..9176b15 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
@@ -21,66 +21,61 @@ package org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect;
import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
import org.apache.tinkerpop.gremlin.process.traversal.Traverser;
import org.apache.tinkerpop.gremlin.process.traversal.step.Mutating;
+import org.apache.tinkerpop.gremlin.process.traversal.step.TraversalParent;
+import org.apache.tinkerpop.gremlin.process.traversal.step.util.Parameters;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.CallbackRegistry;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.Event;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.ListCallbackRegistry;
import org.apache.tinkerpop.gremlin.process.traversal.traverser.TraverserRequirement;
-import org.apache.tinkerpop.gremlin.structure.*;
+import org.apache.tinkerpop.gremlin.structure.Edge;
+import org.apache.tinkerpop.gremlin.structure.Element;
+import org.apache.tinkerpop.gremlin.structure.Property;
+import org.apache.tinkerpop.gremlin.structure.T;
+import org.apache.tinkerpop.gremlin.structure.Vertex;
+import org.apache.tinkerpop.gremlin.structure.VertexProperty;
import org.apache.tinkerpop.gremlin.structure.util.detached.DetachedFactory;
-import java.util.EnumSet;
+import java.util.List;
import java.util.Set;
/**
* @author Marko A. Rodriguez (http://markorodriguez.com)
*/
-public final class AddPropertyStep<S extends Element> extends SideEffectStep<S> implements Mutating<Event.ElementPropertyChangedEvent> {
+public final class AddPropertyStep<S extends Element> extends SideEffectStep<S> implements Mutating<Event.ElementPropertyChangedEvent>, TraversalParent {
- private static final Set<TraverserRequirement> REQUIREMENTS = EnumSet.of(TraverserRequirement.OBJECT);
+ private final Parameters parameters = new Parameters();
private final VertexProperty.Cardinality cardinality;
- private final String key;
- private final Object value;
- private final Object[] vertexPropertyKeyValues;
- private final boolean asVertex;
private CallbackRegistry<Event.ElementPropertyChangedEvent> callbackRegistry;
- public AddPropertyStep(final Traversal.Admin traversal, final VertexProperty.Cardinality cardinality, final String key, final Object value, final Object... vertexPropertyKeyValues) {
+ public AddPropertyStep(final Traversal.Admin traversal, final VertexProperty.Cardinality cardinality, final Object keyObject, final Object valueObject) {
super(traversal);
- this.key = key;
- this.value = value;
- this.vertexPropertyKeyValues = vertexPropertyKeyValues;
- this.asVertex = null != cardinality || this.vertexPropertyKeyValues.length > 0;
- this.cardinality = null == cardinality ? VertexProperty.Cardinality.list : cardinality;
+ this.parameters.set(T.key, keyObject);
+ this.parameters.set(T.value, valueObject);
+ this.cardinality = cardinality;
+ this.parameters.integrateTraversals(this);
}
- public AddPropertyStep(final Traversal.Admin traversal, final String key, final Object value, final Object... vertexPropertyKeyValues) {
- this(traversal, null, key, value, vertexPropertyKeyValues);
- }
-
- public VertexProperty.Cardinality getCardinality() {
- return cardinality;
- }
-
- public String getKey() {
- return key;
- }
-
- public Object getValue() {
- return value;
- }
-
- public Object[] getVertexPropertyKeyValues() {
- return vertexPropertyKeyValues;
+ @Override
+ public <S, E> List<Traversal.Admin<S, E>> getLocalChildren() {
+ return this.parameters.getTraversals();
}
- public boolean isAsVertex() {
- return asVertex;
+ @Override
+ public void addPropertyMutations(final Object... keyValues) {
+ for (int i = 0; i < keyValues.length; i = i + 2) {
+ this.parameters.set(keyValues[i], keyValues[i + 1]);
+ }
+ this.parameters.integrateTraversals(this);
}
@Override
protected void sideEffect(final Traverser.Admin<S> traverser) {
- if (callbackRegistry != null) {
+ final String key = this.parameters.get(traverser, T.key);
+ final Object value = this.parameters.get(traverser, T.value);
+ final Object[] vertexPropertyKeyValues = this.parameters.getKeyValues(traverser, T.key, T.value);
+
+ if (this.callbackRegistry != null) {
final Element currentElement = traverser.get();
final Property currentProperty = traverser.get().property(key);
@@ -101,15 +96,15 @@ public final class AddPropertyStep<S extends Element> extends SideEffectStep<S>
callbackRegistry.getCallbacks().forEach(c -> c.accept(evt));
}
- if (asVertex)
- ((Vertex) traverser.get()).property(cardinality, key, value, vertexPropertyKeyValues);
+ if (null != this.cardinality)
+ ((Vertex) traverser.get()).property(this.cardinality, key, value, vertexPropertyKeyValues);
else
traverser.get().property(key, value);
}
@Override
public Set<TraverserRequirement> getRequirements() {
- return REQUIREMENTS;
+ return this.getSelfAndChildRequirements(TraverserRequirement.OBJECT);
}
@Override
@@ -118,12 +113,11 @@ public final class AddPropertyStep<S extends Element> extends SideEffectStep<S>
return callbackRegistry;
}
+
@Override
public int hashCode() {
- int result = super.hashCode() ^ this.cardinality.hashCode() ^ this.key.hashCode() ^ Integer.rotateLeft(this.value.hashCode(), 16);
- for (final Object item : this.vertexPropertyKeyValues) {
- result ^= item.hashCode();
- }
- return result;
+ return super.hashCode() ^ this.cardinality.hashCode() ^ this.parameters.hashCode();
}
+
+ // TODO clone()
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/util/Parameters.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/util/Parameters.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/util/Parameters.java
new file mode 100644
index 0000000..3a20c8d
--- /dev/null
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/util/Parameters.java
@@ -0,0 +1,96 @@
+/*
+ *
+ * * Licensed to the Apache Software Foundation (ASF) under one
+ * * or more contributor license agreements. See the NOTICE file
+ * * distributed with this work for additional information
+ * * regarding copyright ownership. The ASF licenses this file
+ * * to you under the Apache License, Version 2.0 (the
+ * * "License"); you may not use this file except in compliance
+ * * with the License. You may obtain a copy of the License at
+ * *
+ * * http://www.apache.org/licenses/LICENSE-2.0
+ * *
+ * * Unless required by applicable law or agreed to in writing,
+ * * software distributed under the License is distributed on an
+ * * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * * KIND, either express or implied. See the License for the
+ * * specific language governing permissions and limitations
+ * * under the License.
+ *
+ */
+
+package org.apache.tinkerpop.gremlin.process.traversal.step.util;
+
+import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
+import org.apache.tinkerpop.gremlin.process.traversal.Traverser;
+import org.apache.tinkerpop.gremlin.process.traversal.step.TraversalParent;
+import org.apache.tinkerpop.gremlin.process.traversal.util.TraversalUtil;
+
+import java.io.Serializable;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * @author Marko A. Rodriguez (http://markorodriguez.com)
+ */
+public final class Parameters implements Cloneable, Serializable {
+
+ private static final Object[] EMPTY_ARRAY = new Object[0];
+
+ private Map<Object, Object> parameters = new HashMap<>();
+
+ public <S, E> E get(final Traverser.Admin<S> traverser, final Object key) {
+ final Object object = parameters.get(key);
+ return object instanceof Traversal.Admin ? TraversalUtil.apply(traverser, (Traversal.Admin<S, E>) object) : (E) object;
+ }
+
+ public <S> Object[] getKeyValues(final Traverser.Admin<S> traverser, final Object... exceptKeys) {
+ if (this.parameters.size() == 0) return EMPTY_ARRAY;
+ final List<Object> exceptions = Arrays.asList(exceptKeys);
+ final Object[] keyValues = new Object[(this.parameters.size() * 2) - (exceptKeys.length * 2)];
+ int counter = 0;
+ for (final Map.Entry<Object, Object> keyValue : this.parameters.entrySet()) {
+ if (!exceptions.contains(keyValue.getKey())) {
+ keyValues[counter++] = keyValue.getKey() instanceof Traversal.Admin ? TraversalUtil.apply(traverser, (Traversal.Admin<S, ?>) keyValue.getKey()) : keyValue.getKey();
+ keyValues[counter++] = keyValue.getValue() instanceof Traversal.Admin ? TraversalUtil.apply(traverser, (Traversal.Admin<S, ?>) keyValue.getValue()) : keyValue.getValue();
+ }
+ }
+ return keyValues;
+ }
+
+ public void set(final Object key, final Object value) {
+ if (null != value) this.parameters.put(key, value);
+ }
+
+ public void integrateTraversals(final TraversalParent step) {
+ for (final Object value : this.parameters.values()) {
+ if (value instanceof Traversal.Admin) {
+ step.integrateChild((Traversal.Admin) value);
+ }
+ }
+ }
+
+ public <S, E> List<Traversal.Admin<S, E>> getTraversals() {
+ return (List) this.parameters.values().stream().filter(t -> t instanceof Traversal.Admin).collect(Collectors.toList());
+ }
+
+ public Parameters clone() {
+ try {
+ final Parameters clone = (Parameters) super.clone();
+ clone.parameters = new HashMap<>();
+ for (final Map.Entry<Object, Object> entry : this.parameters.entrySet()) {
+ clone.parameters.put(entry.getKey(), entry.getValue() instanceof Traversal ? ((Traversal.Admin) entry.getValue()).clone() : entry.getValue());
+ }
+ return clone;
+ } catch (final CloneNotSupportedException e) {
+ throw new IllegalStateException(e.getMessage(), e);
+ }
+ }
+
+ public int hashCode() {
+ return this.parameters.hashCode();
+ }
+}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategy.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategy.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategy.java
index 2eca211..6927f56 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategy.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategy.java
@@ -105,20 +105,21 @@ public final class ElementIdStrategy extends AbstractTraversalStrategy<Traversal
// in each case below, determine if the T.id is present and if so, replace T.id with the idPropertyKey or if
// it is not present then shove it in there and generate an id
TraversalHelper.getStepsOfAssignableClass(AddVertexStep.class, traversal).stream().forEach(s -> {
- if (ElementHelper.getIdValue(s.getKeyValues()).isPresent())
- TraversalHelper.replaceStep(s, new AddVertexStep(traversal, ElementHelper.replaceKey(s.getKeyValues(), T.id, idPropertyKey)), traversal);
- else {
+ if (ElementHelper.getIdValue(s.getKeyValues()).isPresent()) {
+
+ //TraversalHelper.replaceStep(s, new AddVertexStep(traversal, ElementHelper.replaceKey(s.getKeyValues(), T.id, idPropertyKey)), traversal);
+ } else {
final Object[] kvs = ElementHelper.getKeys(s.getKeyValues()).contains(idPropertyKey) ? s.getKeyValues() : ElementHelper.upsert(s.getKeyValues(), idPropertyKey, idMaker.get());
- TraversalHelper.replaceStep(s, new AddVertexStep(traversal, kvs), traversal);
+ // TraversalHelper.replaceStep(s, new AddVertexStep(traversal, kvs), traversal);
}
});
TraversalHelper.getStepsOfAssignableClass(AddVertexStartStep.class, traversal).stream().forEach(s -> {
- if (ElementHelper.getIdValue(s.getKeyValues()).isPresent())
- TraversalHelper.replaceStep(s, new AddVertexStartStep(traversal, ElementHelper.replaceKey(s.getKeyValues(), T.id, idPropertyKey)), traversal);
- else {
+ if (ElementHelper.getIdValue(s.getKeyValues()).isPresent()) {
+ // TraversalHelper.replaceStep(s, new AddVertexStartStep(traversal, ElementHelper.replaceKey(s.getKeyValues(), T.id, idPropertyKey)), traversal);
+ } else {
final Object[] kvs = ElementHelper.getKeys(s.getKeyValues()).contains(idPropertyKey) ? s.getKeyValues() : ElementHelper.upsert(s.getKeyValues(), idPropertyKey, idMaker.get());
- TraversalHelper.replaceStep(s, new AddVertexStartStep(traversal, kvs), traversal);
+ // TraversalHelper.replaceStep(s, new AddVertexStartStep(traversal, kvs), traversal);
}
});
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategy.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategy.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategy.java
index a957571..aa0b648 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategy.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategy.java
@@ -95,12 +95,12 @@ public final class PartitionStrategy extends AbstractTraversalStrategy<Traversal
// all write vertex steps need to have partition keys tossed into the property key/value list after mutating steps
TraversalHelper.getStepsOfAssignableClass(AddVertexStep.class, traversal).forEach(s -> {
final Object[] keyValues = injectPartitionInfo(s.getKeyValues());
- TraversalHelper.replaceStep(s, new AddVertexStep(traversal, keyValues), traversal);
+ //TraversalHelper.replaceStep(s, new AddVertexStep(traversal, keyValues), traversal);
});
TraversalHelper.getStepsOfAssignableClass(AddVertexStartStep.class, traversal).forEach(s -> {
final Object[] keyValues = injectPartitionInfo(s.getKeyValues());
- TraversalHelper.replaceStep(s, new AddVertexStartStep(traversal, keyValues), traversal);
+ //TraversalHelper.replaceStep(s, new AddVertexStartStep(traversal, keyValues), traversal);
});
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyTest.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyTest.java b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyTest.java
index 8412e70..fedc874 100644
--- a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyTest.java
+++ b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyTest.java
@@ -51,7 +51,7 @@ public class EventStrategyTest {
{"addE(OUT)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE(Direction.OUT, "test", "test"), 1},
{"addE(OUT,args)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE(Direction.OUT, "test", "test", "this", "that"), 1},
{"addV()", new DefaultGraphTraversal<>(EmptyGraph.instance()).addV(), 1},
- {"addV(args)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addV("test", "this"), 1},
+ // {"addV(args)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addV("test", "this"), 1},
{"addV().property(k,v)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addV().property("test", "that"), 2},
{"properties().drop()", new DefaultGraphTraversal<>(EmptyGraph.instance()).properties().drop(), 1},
{"properties(k).drop()", new DefaultGraphTraversal<>(EmptyGraph.instance()).properties("test").drop(), 1},
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyTest.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyTest.java b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyTest.java
index 41ffb2a..843ecfa 100644
--- a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyTest.java
+++ b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyTest.java
@@ -54,7 +54,7 @@ public class ReadOnlyStrategyTest {
{"out().properties(k).property(k,v)", new DefaultGraphTraversal<>(EmptyGraph.instance()).out().properties("test").property("test", "that")},
{"out().property(k,v)", new DefaultGraphTraversal<>(EmptyGraph.instance()).out().property("test", "test")},
{"out().property(Cardinality,k,v)", new DefaultGraphTraversal<>(EmptyGraph.instance()).out().property(VertexProperty.Cardinality.list, "test", "test")},
- {"addV(args)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addV("test", "test", "this", "that")},
+ {"addV(person)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addV("person")},
{"addV()", new DefaultGraphTraversal<>(EmptyGraph.instance()).addV()}});
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy
----------------------------------------------------------------------
diff --git a/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy b/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy
index 5fe5b86..390ecdb 100644
--- a/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy
+++ b/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy
@@ -19,8 +19,8 @@
package org.apache.tinkerpop.gremlin.process.traversal.step.map
-import org.apache.tinkerpop.gremlin.process.traversal.util.TraversalScriptHelper
import org.apache.tinkerpop.gremlin.process.traversal.Traversal
+import org.apache.tinkerpop.gremlin.process.traversal.util.TraversalScriptHelper
import org.apache.tinkerpop.gremlin.structure.Vertex
/**
@@ -31,13 +31,31 @@ public abstract class GroovyAddVertexTest {
public static class Traversals extends AddVertexTest {
@Override
- public Traversal<Vertex, Vertex> get_g_V_addVXlabel_animal_age_0X() {
+ public Traversal<Vertex, Vertex> get_g_V_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX(
+ final Object v1Id) {
+ TraversalScriptHelper.compute("g.V(${v1Id}).as('a').addV('animal').property('age', select('a').by('age')).property('name', 'puppy')", g, "v1Id", v1Id);
+ }
+
+ @Override
+ public Traversal<Vertex, Vertex> get_g_V_addVXanimalX_propertyXage_0X() {
TraversalScriptHelper.compute("g.V.addV(T.label, 'animal', 'age', 0)", g)
}
@Override
- public Traversal<Vertex, Vertex> get_g_addVXlabel_person_name_stephenX() {
+ public Traversal<Vertex, Vertex> get_g_addVXpersonX_propertyXname_stephenX() {
TraversalScriptHelper.compute("g.addV(T.label, 'person', 'name', 'stephen')", g)
}
+
+ /////////
+
+ @Override
+ public Traversal<Vertex, Vertex> get_g_V_addVXlabel_animal_age_0X() {
+ TraversalScriptHelper.compute("g.V.addV(label, 'animal', 'age', 0)", g)
+ }
+
+ @Override
+ public Traversal<Vertex, Vertex> get_g_addVXlabel_person_name_stephenX() {
+ TraversalScriptHelper.compute("g.V.addV(label, 'person', 'name', 'stephen')", g);
+ }
}
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java
----------------------------------------------------------------------
diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java
index ddf6324..bed5a7f 100644
--- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java
+++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java
@@ -22,10 +22,10 @@ import org.apache.tinkerpop.gremlin.AbstractGremlinTest;
import org.apache.tinkerpop.gremlin.FeatureRequirement;
import org.apache.tinkerpop.gremlin.LoadGraphWith;
import org.apache.tinkerpop.gremlin.process.GremlinProcessRunner;
-import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
-import org.apache.tinkerpop.gremlin.process.traversal.TraversalEngine;
+import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.__;
import org.apache.tinkerpop.gremlin.structure.Graph;
+import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.apache.tinkerpop.gremlin.util.iterator.IteratorUtils;
import org.junit.Test;
@@ -41,13 +41,71 @@ import static org.junit.Assert.assertFalse;
@RunWith(GremlinProcessRunner.class)
public abstract class AddVertexTest extends AbstractGremlinTest {
+ public abstract Traversal<Vertex, Vertex> get_g_V_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX(final Object v1Id);
+
+ public abstract Traversal<Vertex, Vertex> get_g_V_addVXanimalX_propertyXage_0X();
+
+ public abstract Traversal<Vertex, Vertex> get_g_addVXpersonX_propertyXname_stephenX();
+
+ // 3.0.0 DEPRECATIONS
+ @Deprecated
public abstract Traversal<Vertex, Vertex> get_g_V_addVXlabel_animal_age_0X();
+ @Deprecated
public abstract Traversal<Vertex, Vertex> get_g_addVXlabel_person_name_stephenX();
@Test
@LoadGraphWith(MODERN)
@FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
+ public void g_V_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX() {
+ final Traversal<Vertex, Vertex> traversal = get_g_V_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX(convertToVertexId(graph, "marko"));
+ printTraversalForm(traversal);
+ final Vertex vertex = traversal.next();
+ assertEquals("animal", vertex.label());
+ assertEquals(29, vertex.<Integer>value("age").intValue());
+ assertEquals("puppy", vertex.<String>value("name"));
+ assertFalse(traversal.hasNext());
+ assertEquals(7, IteratorUtils.count(graph.vertices()));
+ }
+
+
+ @Test
+ @LoadGraphWith(MODERN)
+ @FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
+ public void g_V_addVXanimalX_propertyXage_0X() {
+ final Traversal<Vertex, Vertex> traversal = get_g_V_addVXanimalX_propertyXage_0X();
+ printTraversalForm(traversal);
+ int count = 0;
+ while (traversal.hasNext()) {
+ final Vertex vertex = traversal.next();
+ assertEquals("animal", vertex.label());
+ assertEquals(0, vertex.<Integer>value("age").intValue());
+ count++;
+ }
+ assertEquals(6, count);
+ assertEquals(12, IteratorUtils.count(graph.vertices()));
+
+ }
+
+ @Test
+ @LoadGraphWith(MODERN)
+ @FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
+ public void g_addVXpersonX_propertyXname_stephenX() {
+ final Traversal<Vertex, Vertex> traversal = get_g_addVXpersonX_propertyXname_stephenX();
+ printTraversalForm(traversal);
+ final Vertex stephen = traversal.next();
+ assertFalse(traversal.hasNext());
+ assertEquals("person", stephen.label());
+ assertEquals("stephen", stephen.value("name"));
+ assertEquals(1, IteratorUtils.count(stephen.properties()));
+ assertEquals(7, IteratorUtils.count(graph.vertices()));
+ }
+
+ /////
+
+ @Test
+ @LoadGraphWith(MODERN)
+ @FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
public void g_V_addVXlabel_animal_age_0X() {
final Traversal<Vertex, Vertex> traversal = get_g_V_addVXlabel_animal_age_0X();
printTraversalForm(traversal);
@@ -81,6 +139,21 @@ public abstract class AddVertexTest extends AbstractGremlinTest {
public static class Traversals extends AddVertexTest {
@Override
+ public Traversal<Vertex, Vertex> get_g_V_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX(final Object v1Id) {
+ return g.V(v1Id).as("a").addV("animal").property("age", __.select("a").by("age")).property("name", "puppy");
+ }
+
+ @Override
+ public Traversal<Vertex, Vertex> get_g_V_addVXanimalX_propertyXage_0X() {
+ return g.V().addV("animal").property("age", 0);
+ }
+
+ @Override
+ public Traversal<Vertex, Vertex> get_g_addVXpersonX_propertyXname_stephenX() {
+ return g.addV("person").property("name", "stephen");
+ }
+
+ @Override
public Traversal<Vertex, Vertex> get_g_V_addVXlabel_animal_age_0X() {
return g.V().addV(T.label, "animal", "age", 0);
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyProcessTest.java
----------------------------------------------------------------------
diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyProcessTest.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyProcessTest.java
index 8d6d6e4..79e0a63 100644
--- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyProcessTest.java
+++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyProcessTest.java
@@ -47,7 +47,7 @@ public class ElementIdStrategyProcessTest extends AbstractGremlinProcessTest {
public void shouldGenerateDefaultIdOnGraphAddVWithGeneratedDefaultId() throws Exception {
final ElementIdStrategy strategy = ElementIdStrategy.build().create();
final GraphTraversalSource sg = create(strategy);
- final Vertex v = sg.addV("name", "stephen").next();
+ final Vertex v = sg.addV().property("name", "stephen").next();
assertEquals("stephen", v.value("name"));
final Traversal t1 = graph.traversal().V(v);
@@ -66,7 +66,7 @@ public class ElementIdStrategyProcessTest extends AbstractGremlinProcessTest {
public void shouldGenerateDefaultIdOnGraphAddVWithGeneratedCustomId() throws Exception {
final ElementIdStrategy strategy = ElementIdStrategy.build().idMaker(() -> "xxx").create();
final GraphTraversalSource sg = create(strategy);
- final Vertex v = sg.addV("name", "stephen").next();
+ final Vertex v = sg.addV().property("name", "stephen").next();
assertEquals("stephen", v.value("name"));
assertEquals("xxx", sg.V(v).id().next());
assertEquals("xxx", sg.V("xxx").id().next());
@@ -77,33 +77,35 @@ public class ElementIdStrategyProcessTest extends AbstractGremlinProcessTest {
public void shouldSetIdOnAddVWithIdPropertyKeySpecifiedAndNameSuppliedAsProperty() throws Exception {
final ElementIdStrategy strategy = ElementIdStrategy.build().idPropertyKey("name").create();
final GraphTraversalSource sg = create(strategy);
- final Vertex v = sg.addV("name", "stephen").next();
+ final Vertex v = sg.addV().property("name", "stephen").next();
assertEquals("stephen", v.value("name"));
assertEquals("stephen", sg.V(v).id().next());
assertEquals("stephen", sg.V("stephen").id().next());
}
- @Test
+ /*@Test
@FeatureRequirementSet(FeatureRequirementSet.Package.VERTICES_ONLY)
public void shouldSetIdOnAddVWithIdPropertyKeySpecifiedAndIdSuppliedAsProperty() throws Exception {
final ElementIdStrategy strategy = ElementIdStrategy.build().idPropertyKey("name").create();
final GraphTraversalSource sg = create(strategy);
- final Vertex v = sg.addV(T.id, "stephen").next();
+ final Vertex v = sg.addV().property(T.id, "stephen").next();
assertEquals("stephen", v.value("name"));
assertEquals("stephen", sg.V(v).id().next());
assertEquals("stephen", sg.V("stephen").id().next());
- }
+ }*/
+ /*
@Test
@FeatureRequirementSet(FeatureRequirementSet.Package.VERTICES_ONLY)
public void shouldGenerateDefaultIdOnGraphAddVWithSpecifiedId() throws Exception {
final ElementIdStrategy strategy = ElementIdStrategy.build().create();
final GraphTraversalSource sg = create(strategy);
- final Vertex v = sg.addV(T.id, "STEPHEN", "name", "stephen").next();
+ final Vertex v = sg.addV().property(T.id, "STEPHEN", "name", "stephen").next();
assertEquals("stephen", v.value("name"));
assertEquals("STEPHEN", sg.V(v).id().next());
assertEquals("STEPHEN", sg.V("STEPHEN").id().next());
}
+ */
@Test
@FeatureRequirementSet(FeatureRequirementSet.Package.VERTICES_ONLY)
@@ -113,7 +115,7 @@ public class ElementIdStrategyProcessTest extends AbstractGremlinProcessTest {
sg.addV().next();
assertEquals(1, IteratorUtils.count(sg.V()));
- final Vertex v = sg.V().addV("name", "stephen").next();
+ final Vertex v = sg.V().addV().property("name", "stephen").next();
assertEquals("stephen", v.value("name"));
assertNotNull(UUID.fromString(sg.V(v).id().next().toString()));
}
@@ -131,14 +133,15 @@ public class ElementIdStrategyProcessTest extends AbstractGremlinProcessTest {
sg.addV().next();
assertEquals(1, IteratorUtils.count(sg.V()));
- final Vertex v = sg.V().addV("name", "stephen").next();
+ final Vertex v = sg.V().addV().property("name", "stephen").next();
assertEquals("stephen", v.value("name"));
assertEquals("xxx", sg.V(v).id().next());
assertEquals("xxx", sg.V("xxx").id().next());
assertEquals("yyy", sg.V("yyy").id().next());
}
- @Test
+ /*@Test
+ //TODO
@FeatureRequirementSet(FeatureRequirementSet.Package.VERTICES_ONLY)
public void shouldGenerateDefaultIdOnAddVWithSpecifiedId() throws Exception {
final ElementIdStrategy strategy = ElementIdStrategy.build().create();
@@ -150,7 +153,7 @@ public class ElementIdStrategyProcessTest extends AbstractGremlinProcessTest {
assertEquals("stephen", v.value("name"));
assertEquals("STEPHEN", sg.V(v).id().next());
assertEquals("STEPHEN", sg.V("STEPHEN").id().next());
- }
+ }*/
@Test
@FeatureRequirementSet(FeatureRequirementSet.Package.SIMPLE)
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyProcessTest.java
----------------------------------------------------------------------
diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyProcessTest.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyProcessTest.java
index 910f9f4..d38e1a8 100644
--- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyProcessTest.java
+++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyProcessTest.java
@@ -61,7 +61,7 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
graph.addVertex("some", "thing");
final GraphTraversalSource gts = create(eventStrategy);
- gts.V().addV("any", "thing").next();
+ gts.V().addV().property("any", "thing").next();
tryCommit(graph, g -> assertEquals(1, IteratorUtils.count(gts.V().has("any", "thing"))));
assertEquals(1, listener1.addVertexEventRecorded());
@@ -84,7 +84,7 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
graph.addVertex("some", "thing");
final GraphTraversalSource gts = create(eventStrategy);
- gts.addV("any", "thing").next();
+ gts.addV().property("any", "thing").next();
tryCommit(graph, g -> assertEquals(1, IteratorUtils.count(gts.V().has("any", "thing"))));
assertEquals(1, listener1.addVertexEventRecorded());
@@ -193,7 +193,7 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
final Vertex vSome = graph.addVertex("some", "thing");
vSome.property(VertexProperty.Cardinality.single, "that", "thing");
final GraphTraversalSource gts = create(eventStrategy);
- gts.V().addV("any", "thing").property(VertexProperty.Cardinality.single, "this", "thing").next();
+ gts.V().addV().property("any", "thing").property(VertexProperty.Cardinality.single, "this", "thing").next();
tryCommit(graph, g -> assertEquals(1, IteratorUtils.count(gts.V().has("this", "thing"))));
@@ -220,7 +220,7 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
final Vertex vSome = graph.addVertex("some", "thing");
vSome.property(VertexProperty.Cardinality.single, "that", "thing");
final GraphTraversalSource gts = create(eventStrategy);
- final Vertex vAny = gts.V().addV("any", "thing").next();
+ final Vertex vAny = gts.V().addV().property("any", "thing").next();
gts.V(vAny).property(VertexProperty.Cardinality.single, "any", "thing else").next();
tryCommit(graph, g -> assertEquals(1, IteratorUtils.count(gts.V().has("any", "thing else"))));
@@ -249,7 +249,7 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
final Vertex vSome = graph.addVertex("some", "thing");
vSome.property(VertexProperty.Cardinality.single, "that", "thing", "is", "good");
final GraphTraversalSource gts = create(eventStrategy);
- final Vertex vAny = gts.V().addV("any", "thing").next();
+ final Vertex vAny = gts.V().addV().property("any", "thing").next();
gts.V(vAny).properties("any").property("is", "bad").next();
tryCommit(graph, g -> assertEquals(1, IteratorUtils.count(gts.V().has("any", "thing"))));
@@ -442,7 +442,7 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
final Vertex vSome = graph.addVertex("some", "thing");
vSome.property(VertexProperty.Cardinality.single, "that", "thing", "is", "good");
final GraphTraversalSource gts = create(eventStrategy);
- final Vertex vAny = gts.V().addV("any", "thing").next();
+ final Vertex vAny = gts.V().addV().property("any", "thing").next();
gts.V(vAny).properties("any").property("is", "bad").next();
gts.V(vAny).properties("any").properties("is").drop().iterate();
@@ -471,8 +471,8 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
graph.addVertex("some", "thing");
final GraphTraversalSource gts = create(eventStrategy);
- gts.V().addV("any", "thing").next();
- gts.V().addV("any", "one").next();
+ gts.V().addV().property("any", "thing").next();
+ gts.V().addV().property("any", "one").next();
assertEquals(0, listener1.addVertexEventRecorded());
assertEquals(0, listener2.addVertexEventRecorded());
@@ -499,8 +499,8 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
graph.addVertex("some", "thing");
final GraphTraversalSource gts = create(eventStrategy);
- gts.V().addV("any", "thing").next();
- gts.V().addV("any", "one").next();
+ gts.V().addV().property("any", "thing").next();
+ gts.V().addV().property("any", "one").next();
assertEquals(0, listener1.addVertexEventRecorded());
assertEquals(0, listener2.addVertexEventRecorded());
@@ -512,8 +512,8 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
assertEquals(0, listener2.addVertexEventRecorded());
graph.addVertex("some", "thing");
- gts.V().addV("any", "thing").next();
- gts.V().addV("any", "one").next();
+ gts.V().addV().property("any", "thing").next();
+ gts.V().addV().property("any", "one").next();
assertEquals(0, listener1.addVertexEventRecorded());
assertEquals(0, listener2.addVertexEventRecorded());
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyProcessTest.java
----------------------------------------------------------------------
diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyProcessTest.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyProcessTest.java
index 67fe639..5bc2982 100644
--- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyProcessTest.java
+++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyProcessTest.java
@@ -40,7 +40,7 @@ public class PartitionStrategyProcessTest extends AbstractGremlinProcessTest {
public void shouldAppendPartitionToVertex() {
final PartitionStrategy partitionStrategy = PartitionStrategy.build()
.partitionKey(partition).writePartition("A").addReadPartition("A").create();
- final Vertex v = create(partitionStrategy).addV("any", "thing").next();
+ final Vertex v = create(partitionStrategy).addV().property("any", "thing").next();
assertNotNull(v);
assertEquals("thing", v.property("any").value());
@@ -53,8 +53,8 @@ public class PartitionStrategyProcessTest extends AbstractGremlinProcessTest {
final PartitionStrategy partitionStrategy = PartitionStrategy.build()
.partitionKey(partition).writePartition("A").addReadPartition("A").create();
final GraphTraversalSource source = create(partitionStrategy);
- final Vertex v1 = source.addV("any", "thing").next();
- final Vertex v2 = source.addV("some", "thing").next();
+ final Vertex v1 = source.addV().property("any", "thing").next();
+ final Vertex v2 = source.addV().property("some", "thing").next();
final Edge e = source.withSideEffect("v2", v2).V(v1.id()).addInE("connectsTo", "v2", "every", "thing").next();
assertNotNull(v1);
@@ -91,8 +91,8 @@ public class PartitionStrategyProcessTest extends AbstractGremlinProcessTest {
final GraphTraversalSource sourceBAB = create(partitionStrategyBAB);
- final Vertex vA = sourceAA.addV("any", "a").next();
- final Vertex vB = sourceBA.addV("any", "b").next();
+ final Vertex vA = sourceAA.addV().property("any", "a").next();
+ final Vertex vB = sourceBA.addV().property("any", "b").next();
assertNotNull(vA);
assertEquals("a", vA.property("any").value());
@@ -119,7 +119,7 @@ public class PartitionStrategyProcessTest extends AbstractGremlinProcessTest {
.partitionKey(partition).writePartition("A").create();
final GraphTraversalSource sourceA = create(partitionStrategyA);
- final Vertex vA = sourceAA.addV("any", "a").next();
+ final Vertex vA = sourceAA.addV().property("any", "a").next();
assertEquals(vA.id(), sourceAA.V(vA.id()).id().next());
try {
@@ -142,7 +142,7 @@ public class PartitionStrategyProcessTest extends AbstractGremlinProcessTest {
.partitionKey(partition).writePartition("A").create();
final GraphTraversalSource sourceA = create(partitionStrategyA);
- final Vertex vA = sourceAA.addV("any", "a").next();
+ final Vertex vA = sourceAA.addV().property("any", "a").next();
final Edge e = sourceAA.withSideEffect("vA", vA).V(vA.id()).addOutE("knows", "vA").next();
assertEquals(e.id(), g.E(e.id()).id().next());
@@ -194,14 +194,14 @@ public class PartitionStrategyProcessTest extends AbstractGremlinProcessTest {
.partitionKey(partition).writePartition("C").addReadPartition("C").addReadPartition("B").create();
final GraphTraversalSource sourceCBC = create(partitionStrategyCBC);
- final Vertex vA = sourceAA.addV("any", "a").next();
- final Vertex vAA = sourceAA.addV("any", "aa").next();
+ final Vertex vA = sourceAA.addV().property("any", "a").next();
+ final Vertex vAA = sourceAA.addV().property("any", "aa").next();
final Edge eAtoAA = sourceAA.withSideEffect("vAA", vAA).V(vA.id()).addOutE("a->a", "vAA").next();
- final Vertex vB = sourceBA.addV("any", "b").next();
+ final Vertex vB = sourceBA.addV().property("any", "b").next();
sourceBA.withSideEffect("vB", vB).V(vA.id()).addOutE("a->b", "vB").next();
- final Vertex vC = sourceCAB.addV("any", "c").next();
+ final Vertex vC = sourceCAB.addV().property("any", "c").next();
final Edge eBtovC = sourceCAB.withSideEffect("vC", vC).V(vB.id()).addOutE("b->c", "vC").next();
final Edge eAtovC = sourceCAB.withSideEffect("vC", vC).V(vA.id()).addOutE("a->c", "vC").next();
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/6ffcca3c/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/structure/TinkerGraphTest.java
----------------------------------------------------------------------
diff --git a/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/structure/TinkerGraphTest.java b/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/structure/TinkerGraphTest.java
index 0b33280..194fbe5 100644
--- a/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/structure/TinkerGraphTest.java
+++ b/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/structure/TinkerGraphTest.java
@@ -171,7 +171,8 @@ public class TinkerGraphTest {
//System.out.println(g.V().properties().key().groupCount().next());
TinkerGraph graph = TinkerFactory.createModern();
GraphTraversalSource g = graph.traversal(GraphTraversalSource.standard());
- final List<Supplier<GraphTraversal<?,?>>> traversals = Arrays.asList(
+ g.V().as("a").addV("animal").property("age",select("a").by("age")).forEachRemaining(System.out::println);
+ /*final List<Supplier<GraphTraversal<?,?>>> traversals = Arrays.asList(
() -> g.V().out().as("v").match(
__.as("v").outE().count().as("outDegree"),
__.as("v").inE().count().as("inDegree")).select("v","outDegree","inDegree").by(valueMap()).by().by().local(union(select("v"), select("inDegree", "outDegree")).unfold().fold())
@@ -181,7 +182,7 @@ public class TinkerGraphTest {
System.out.println("pre-strategy: " + traversal.get());
System.out.println("post-strategy: " + traversal.get().iterate());
System.out.println(TimeUtil.clockWithResult(50, () -> traversal.get().toList()));
- });
+ });*/
}
@Test
[4/8] incubator-tinkerpop git commit: simplifications of Parameters
and their usage in the AddXXXSteps. Man,
this new model really simplified things even though, paradoxically,
its provides more complex behavior.
Posted by ok...@apache.org.
simplifications of Parameters and their usage in the AddXXXSteps. Man, this new model really simplified things even though, paradoxically, its provides more complex behavior.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/085cd168
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/085cd168
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/085cd168
Branch: refs/heads/master
Commit: 085cd168e8ff2eba8d1f4555ae49db9a5c51a529
Parents: f314fe6
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Tue Aug 25 17:33:19 2015 -0600
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Tue Aug 25 17:33:19 2015 -0600
----------------------------------------------------------------------
.../traversal/dsl/graph/GraphTraversal.java | 5 +--
.../process/traversal/step/map/AddEdgeStep.java | 46 ++++++++++----------
.../traversal/step/map/AddVertexStartStep.java | 34 ++++++++++-----
.../traversal/step/map/AddVertexStep.java | 29 +++++++-----
.../step/sideEffect/AddPropertyStep.java | 34 ++++++++++-----
.../process/traversal/step/util/Parameters.java | 10 +++--
6 files changed, 95 insertions(+), 63 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/085cd168/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
index 2fdb3e2..2fad998 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
@@ -687,7 +687,6 @@ public interface GraphTraversal<S, E> extends Traversal<S, E> {
*/
@Deprecated
public default GraphTraversal<S, Edge> addE(final Direction direction, final String firstVertexKeyOrEdgeLabel, final String edgeLabelOrSecondVertexKey, final Object... propertyKeyValues) {
-
if (propertyKeyValues.length % 2 == 0) {
// addOutE("createdBy", "a")
this.addE(firstVertexKeyOrEdgeLabel);
@@ -991,9 +990,7 @@ public interface GraphTraversal<S, E> extends Traversal<S, E> {
return this.asAdmin().addStep(new ProfileStep<>(this.asAdmin()));
}
-
- public default GraphTraversal<S, E> property(final VertexProperty.Cardinality cardinality, final Object key,
- final Object value, final Object... keyValues) {
+ public default GraphTraversal<S, E> property(final VertexProperty.Cardinality cardinality, final Object key, final Object value, final Object... keyValues) {
if ((this.asAdmin().getEndStep() instanceof AddVertexStep || this.asAdmin().getEndStep() instanceof AddEdgeStep || this.asAdmin().getEndStep() instanceof AddVertexStartStep) && keyValues.length == 0) {
((Mutating) this.asAdmin().getEndStep()).addPropertyMutations(new Object[]{key, value});
} else {
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/085cd168/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java
index dbd6491..6a83a59 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java
@@ -34,9 +34,7 @@ import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.apache.tinkerpop.gremlin.structure.util.StringFactory;
import org.apache.tinkerpop.gremlin.structure.util.detached.DetachedFactory;
-import org.apache.tinkerpop.gremlin.util.iterator.IteratorUtils;
-import java.util.Iterator;
import java.util.List;
import java.util.Set;
@@ -44,12 +42,12 @@ import java.util.Set;
* @author Marko A. Rodriguez (http://markorodriguez.com)
* @author Stephen Mallette (http://stephen.genoprime.com)
*/
-public final class AddEdgeStep<S> extends FlatMapStep<S, Edge> implements Mutating<Event.EdgeAddedEvent>, TraversalParent, Parameterizing {
+public final class AddEdgeStep<S> extends MapStep<S, Edge> implements Mutating<Event.EdgeAddedEvent>, TraversalParent, Parameterizing {
private static final String FROM = Graph.Hidden.hide("from");
private static final String TO = Graph.Hidden.hide("to");
- private final Parameters parameters = new Parameters();
+ private Parameters parameters = new Parameters();
private CallbackRegistry<Event.EdgeAddedEvent> callbackRegistry;
public AddEdgeStep(final Traversal.Admin traversal, final String edgeLabel) {
@@ -69,9 +67,7 @@ public final class AddEdgeStep<S> extends FlatMapStep<S, Edge> implements Mutati
@Override
public void addPropertyMutations(final Object... keyValues) {
- for (int i = 0; i < keyValues.length; i = i + 2) {
- this.parameters.set(keyValues[i], keyValues[i + 1]);
- }
+ this.parameters.set(keyValues);
this.parameters.integrateTraversals(this);
}
@@ -86,18 +82,16 @@ public final class AddEdgeStep<S> extends FlatMapStep<S, Edge> implements Mutati
}
@Override
- protected Iterator<Edge> flatMap(final Traverser.Admin<S> traverser) {
- final Vertex toVertex = this.parameters.get(traverser, TO, () -> (Vertex) traverser.get());
- final Vertex fromVertex = this.parameters.get(traverser, FROM, () -> (Vertex) traverser.get());
- final String edgeLabel = this.parameters.get(traverser, T.label, () -> Edge.DEFAULT_LABEL);
-
- final Iterator<Edge> edgeIterator = IteratorUtils.of(fromVertex.addEdge(edgeLabel, toVertex, this.parameters.getKeyValues(traverser, TO, FROM, T.label)));
- return IteratorUtils.consume(edgeIterator, edge -> {
- if (callbackRegistry != null) {
- final Event.EdgeAddedEvent vae = new Event.EdgeAddedEvent(DetachedFactory.detach(edge, true));
- callbackRegistry.getCallbacks().forEach(c -> c.accept(vae));
- }
- });
+ protected Edge map(final Traverser.Admin<S> traverser) {
+ final Edge edge =
+ this.parameters.get(traverser, FROM, () -> (Vertex) traverser.get()).
+ addEdge(this.parameters.get(traverser, T.label, () -> Edge.DEFAULT_LABEL),
+ this.parameters.get(traverser, TO, () -> (Vertex) traverser.get()), this.parameters.getKeyValues(traverser, TO, FROM, T.label));
+ if (callbackRegistry != null) {
+ final Event.EdgeAddedEvent vae = new Event.EdgeAddedEvent(DetachedFactory.detach(edge, true));
+ callbackRegistry.getCallbacks().forEach(c -> c.accept(vae));
+ }
+ return edge;
}
@Override
@@ -107,14 +101,13 @@ public final class AddEdgeStep<S> extends FlatMapStep<S, Edge> implements Mutati
@Override
public CallbackRegistry<Event.EdgeAddedEvent> getMutatingCallbackRegistry() {
- if (null == callbackRegistry) callbackRegistry = new ListCallbackRegistry<>();
- return callbackRegistry;
+ if (null == this.callbackRegistry) this.callbackRegistry = new ListCallbackRegistry<>();
+ return this.callbackRegistry;
}
@Override
public int hashCode() {
- int result = super.hashCode() ^ this.parameters.hashCode();
- return result;
+ return super.hashCode() ^ this.parameters.hashCode();
}
@Override
@@ -122,4 +115,11 @@ public final class AddEdgeStep<S> extends FlatMapStep<S, Edge> implements Mutati
return StringFactory.stepString(this, this.parameters.toString());
}
+ @Override
+ public AddEdgeStep<S> clone() {
+ final AddEdgeStep<S> clone = (AddEdgeStep<S>) super.clone();
+ clone.parameters = this.parameters.clone();
+ return clone;
+ }
+
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/085cd168/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java
index da5cf71..7313bd8 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java
@@ -33,6 +33,7 @@ import org.apache.tinkerpop.gremlin.process.traversal.traverser.util.EmptyTraver
import org.apache.tinkerpop.gremlin.process.traversal.util.FastNoSuchElementException;
import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
+import org.apache.tinkerpop.gremlin.structure.util.StringFactory;
import org.apache.tinkerpop.gremlin.structure.util.detached.DetachedFactory;
import java.util.List;
@@ -44,7 +45,7 @@ import java.util.Set;
*/
public final class AddVertexStartStep extends AbstractStep<Vertex, Vertex> implements Mutating<Event.VertexAddedEvent>, TraversalParent, Parameterizing {
- private final Parameters parameters = new Parameters();
+ private Parameters parameters = new Parameters();
private boolean first = true;
private CallbackRegistry<Event.VertexAddedEvent> callbackRegistry;
@@ -66,9 +67,7 @@ public final class AddVertexStartStep extends AbstractStep<Vertex, Vertex> imple
@Override
public void addPropertyMutations(final Object... keyValues) {
- for (int i = 0; i < keyValues.length; i = i + 2) {
- this.parameters.set(keyValues[i], keyValues[i + 1]);
- }
+ this.parameters.set(keyValues);
this.parameters.integrateTraversals(this);
}
@@ -76,21 +75,20 @@ public final class AddVertexStartStep extends AbstractStep<Vertex, Vertex> imple
protected Traverser<Vertex> processNextStart() {
if (this.first) {
this.first = false;
- final Vertex v = this.getTraversal().getGraph().get().addVertex(this.parameters.getKeyValues(EmptyTraverser.instance()));
- if (callbackRegistry != null) {
- final Event.VertexAddedEvent vae = new Event.VertexAddedEvent(DetachedFactory.detach(v, true));
- callbackRegistry.getCallbacks().forEach(c -> c.accept(vae));
+ final Vertex vertex = this.getTraversal().getGraph().get().addVertex(this.parameters.getKeyValues(EmptyTraverser.instance()));
+ if (this.callbackRegistry != null) {
+ final Event.VertexAddedEvent vae = new Event.VertexAddedEvent(DetachedFactory.detach(vertex, true));
+ this.callbackRegistry.getCallbacks().forEach(c -> c.accept(vae));
}
-
- return this.getTraversal().getTraverserGenerator().generate(v, this, 1l);
+ return this.getTraversal().getTraverserGenerator().generate(vertex, this, 1l);
} else
throw FastNoSuchElementException.instance();
}
@Override
public CallbackRegistry<Event.VertexAddedEvent> getMutatingCallbackRegistry() {
- if (null == callbackRegistry) callbackRegistry = new ListCallbackRegistry<>();
- return callbackRegistry;
+ if (null == this.callbackRegistry) this.callbackRegistry = new ListCallbackRegistry<>();
+ return this.callbackRegistry;
}
@Override
@@ -108,4 +106,16 @@ public final class AddVertexStartStep extends AbstractStep<Vertex, Vertex> imple
super.reset();
this.first = false;
}
+
+ @Override
+ public String toString() {
+ return StringFactory.stepString(this, this.parameters);
+ }
+
+ @Override
+ public AddVertexStartStep clone() {
+ final AddVertexStartStep clone = (AddVertexStartStep) super.clone();
+ clone.parameters = this.parameters.clone();
+ return clone;
+ }
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/085cd168/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java
index 2e813f8..1d5e8c0 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java
@@ -30,6 +30,7 @@ import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.ListCallba
import org.apache.tinkerpop.gremlin.process.traversal.traverser.TraverserRequirement;
import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
+import org.apache.tinkerpop.gremlin.structure.util.StringFactory;
import org.apache.tinkerpop.gremlin.structure.util.detached.DetachedFactory;
import java.util.List;
@@ -41,7 +42,7 @@ import java.util.Set;
*/
public final class AddVertexStep<S> extends MapStep<S, Vertex> implements Mutating<Event.VertexAddedEvent>, TraversalParent, Parameterizing {
- private final Parameters parameters = new Parameters();
+ private Parameters parameters = new Parameters();
private CallbackRegistry<Event.VertexAddedEvent> callbackRegistry;
public AddVertexStep(final Traversal.Admin traversal, final String label) {
@@ -62,20 +63,18 @@ public final class AddVertexStep<S> extends MapStep<S, Vertex> implements Mutati
@Override
public void addPropertyMutations(final Object... keyValues) {
- for (int i = 0; i < keyValues.length; i = i + 2) {
- this.parameters.set(keyValues[i], keyValues[i + 1]);
- }
+ this.parameters.set(keyValues);
this.parameters.integrateTraversals(this);
}
@Override
protected Vertex map(final Traverser.Admin<S> traverser) {
- final Vertex v = this.getTraversal().getGraph().get().addVertex(this.parameters.getKeyValues(traverser));
- if (callbackRegistry != null) {
- final Event.VertexAddedEvent vae = new Event.VertexAddedEvent(DetachedFactory.detach(v, true));
- callbackRegistry.getCallbacks().forEach(c -> c.accept(vae));
+ final Vertex vertex = this.getTraversal().getGraph().get().addVertex(this.parameters.getKeyValues(traverser));
+ if (this.callbackRegistry != null) {
+ final Event.VertexAddedEvent vae = new Event.VertexAddedEvent(DetachedFactory.detach(vertex, true));
+ this.callbackRegistry.getCallbacks().forEach(c -> c.accept(vae));
}
- return v;
+ return vertex;
}
@Override
@@ -94,5 +93,15 @@ public final class AddVertexStep<S> extends MapStep<S, Vertex> implements Mutati
return this.getSelfAndChildRequirements();
}
- // TODO clone()
+ @Override
+ public String toString() {
+ return StringFactory.stepString(this, this.parameters);
+ }
+
+ @Override
+ public AddVertexStep<S> clone() {
+ final AddVertexStep<S> clone = (AddVertexStep<S>) super.clone();
+ clone.parameters = this.parameters.clone();
+ return clone;
+ }
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/085cd168/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
index d6771ae..ccae521 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
@@ -34,6 +34,7 @@ import org.apache.tinkerpop.gremlin.structure.Property;
import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.apache.tinkerpop.gremlin.structure.VertexProperty;
+import org.apache.tinkerpop.gremlin.structure.util.StringFactory;
import org.apache.tinkerpop.gremlin.structure.util.detached.DetachedFactory;
import java.util.List;
@@ -44,8 +45,7 @@ import java.util.Set;
*/
public final class AddPropertyStep<S extends Element> extends SideEffectStep<S> implements Mutating<Event.ElementPropertyChangedEvent>, TraversalParent, Parameterizing {
- private final Parameters parameters = new Parameters();
-
+ private Parameters parameters = new Parameters();
private final VertexProperty.Cardinality cardinality;
private CallbackRegistry<Event.ElementPropertyChangedEvent> callbackRegistry;
@@ -69,16 +69,18 @@ public final class AddPropertyStep<S extends Element> extends SideEffectStep<S>
@Override
public void addPropertyMutations(final Object... keyValues) {
- for (int i = 0; i < keyValues.length; i = i + 2) {
- this.parameters.set(keyValues[i], keyValues[i + 1]);
- }
+ this.parameters.set(keyValues);
this.parameters.integrateTraversals(this);
}
@Override
protected void sideEffect(final Traverser.Admin<S> traverser) {
- final String key = this.parameters.get(traverser, T.key, null);
- final Object value = this.parameters.get(traverser, T.value, null);
+ final String key = this.parameters.get(traverser, T.key, () -> {
+ throw new IllegalStateException("The AddPropertyStep does not have a provided key: " + this);
+ });
+ final Object value = this.parameters.get(traverser, T.value, () -> {
+ throw new IllegalStateException("The AddPropertyStep does not have a provided value: " + this);
+ });
final Object[] vertexPropertyKeyValues = this.parameters.getKeyValues(traverser, T.key, T.value);
if (this.callbackRegistry != null) {
@@ -99,7 +101,7 @@ public final class AddPropertyStep<S extends Element> extends SideEffectStep<S>
else
throw new IllegalStateException(String.format("The incoming object cannot be processed by change eventing in %s: %s", AddPropertyStep.class.getName(), currentElement));
- callbackRegistry.getCallbacks().forEach(c -> c.accept(evt));
+ this.callbackRegistry.getCallbacks().forEach(c -> c.accept(evt));
}
if (null != this.cardinality)
@@ -115,8 +117,8 @@ public final class AddPropertyStep<S extends Element> extends SideEffectStep<S>
@Override
public CallbackRegistry<Event.ElementPropertyChangedEvent> getMutatingCallbackRegistry() {
- if (null == callbackRegistry) callbackRegistry = new ListCallbackRegistry<>();
- return callbackRegistry;
+ if (null == this.callbackRegistry) this.callbackRegistry = new ListCallbackRegistry<>();
+ return this.callbackRegistry;
}
@@ -125,5 +127,15 @@ public final class AddPropertyStep<S extends Element> extends SideEffectStep<S>
return super.hashCode() ^ this.parameters.hashCode() ^ ((null == this.cardinality) ? "null".hashCode() : this.cardinality.hashCode());
}
- // TODO clone()
+ @Override
+ public String toString() {
+ return StringFactory.stepString(this, this.parameters);
+ }
+
+ @Override
+ public AddPropertyStep<S> clone() {
+ final AddPropertyStep<S> clone = (AddPropertyStep<S>)super.clone();
+ clone.parameters = this.parameters.clone();
+ return clone;
+ }
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/085cd168/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/util/Parameters.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/util/Parameters.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/util/Parameters.java
index 55f814f..5af3cc4 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/util/Parameters.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/util/Parameters.java
@@ -57,7 +57,7 @@ public final class Parameters implements Cloneable, Serializable {
return null == object ? defaultValue.get() : object instanceof Traversal.Admin ? TraversalUtil.apply(traverser, (Traversal.Admin<S, E>) object) : (E) object;
}
- public <S, E> E get(final Object key, final Supplier<E> defaultValue) {
+ public <E> E get(final Object key, final Supplier<E> defaultValue) {
final Object object = parameters.get(key);
return null == object ? defaultValue.get() : (E) object;
}
@@ -75,8 +75,12 @@ public final class Parameters implements Cloneable, Serializable {
return keyValues.toArray(new Object[keyValues.size()]);
}
- public void set(final Object key, final Object value) {
- if (null != value) this.parameters.put(key, value);
+ public void set(final Object... keyValues) {
+ for (int i = 0; i < keyValues.length; i = i + 2) {
+ if (keyValues[i + 1] != null) {
+ this.parameters.put(keyValues[i], keyValues[i + 1]);
+ }
+ }
}
public void integrateTraversals(final TraversalParent step) {
[2/8] incubator-tinkerpop git commit: New mutation model that is
backwards compatible (though Deprecation) with old mutation model.
Posted by ok...@apache.org.
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeTest.java
----------------------------------------------------------------------
diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeTest.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeTest.java
index 5940f1d..15eab91 100644
--- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeTest.java
+++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeTest.java
@@ -29,11 +29,13 @@ 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.util.iterator.IteratorUtils;
+import org.junit.Ignore;
import org.junit.Test;
import org.junit.runner.RunWith;
import static org.apache.tinkerpop.gremlin.LoadGraphWith.GraphData.MODERN;
-import static org.junit.Assert.*;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
/**
* @author Marko A. Rodriguez (http://markorodriguez.com)
@@ -42,21 +44,56 @@ import static org.junit.Assert.*;
@RunWith(GremlinProcessRunner.class)
public abstract class AddEdgeTest extends AbstractGremlinProcessTest {
+ public abstract Traversal<Vertex, Edge> get_g_VX1X_asXaX_outXcreatedX_addEXcreatedByX_toXaX(final Object v1Id);
+
+ public abstract Traversal<Vertex, Edge> get_g_VX1X_asXaX_outXcreatedX_addEXcreatedByX_toXaX_propertyXweight_2X(final Object v1Id);
+
+ public abstract Traversal<Vertex, Edge> get_g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_addEXcodeveloperX_fromXaX_toXbX_propertyXyear_2009X();
+
+ public abstract Traversal<Vertex, Edge> get_g_V_asXaX_inXcreatedX_addEXcreatedByX_fromXaX_propertyXyear_2009X_propertyXacl_publicX();
+
+ ///////
+
+ @Deprecated
public abstract Traversal<Vertex, Edge> get_g_VX1X_asXaX_outXcreatedX_addOutEXcreatedBy_aX(final Object v1Id);
+ @Deprecated
public abstract Traversal<Vertex, Edge> get_g_VX1X_asXaX_outXcreatedX_addOutEXcreatedBy_a_weight_2X(final Object v1Id);
+ @Deprecated
public abstract Traversal<Vertex, Edge> get_g_withSideEffectXx__g_V_toListX_addOutEXexistsWith_x_time_nowX();
- public abstract Traversal<Vertex,Edge> get_g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_selectXa_bX_addInEXa_codeveloper_b_year_2009X();
+ @Deprecated
+ public abstract Traversal<Vertex, Edge> get_g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_selectXa_bX_addInEXa_codeveloper_b_year_2009X();
- public abstract Traversal<Vertex,Edge> get_g_V_asXaX_inXcreatedX_addInEXcreatedBy_a_year_2009_acl_publicX();
+ @Deprecated
+ public abstract Traversal<Vertex, Edge> get_g_V_asXaX_inXcreatedX_addInEXcreatedBy_a_year_2009_acl_publicX();
@Test
@LoadGraphWith(MODERN)
+ @Deprecated
@FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
public void g_VX1X_asXaX_outXcreatedX_addOutEXcreatedBy_aX() {
- final Traversal<Vertex, Edge> traversal = get_g_VX1X_asXaX_outXcreatedX_addOutEXcreatedBy_aX(convertToVertexId("marko"));
+ Traversal<Vertex, Edge> traversal = get_g_VX1X_asXaX_outXcreatedX_addOutEXcreatedBy_aX(convertToVertexId("marko"));
+ printTraversalForm(traversal);
+ int count = 0;
+ while (traversal.hasNext()) {
+ final Edge edge = traversal.next();
+ assertEquals("createdBy", edge.label());
+ assertEquals(0, IteratorUtils.count(edge.properties()));
+ count++;
+
+ }
+ assertEquals(1, count);
+ assertEquals(7, IteratorUtils.count(graph.edges()));
+ assertEquals(6, IteratorUtils.count(graph.vertices()));
+ }
+
+ @Test
+ @LoadGraphWith(MODERN)
+ @FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
+ public void g_VX1X_asXaX_outXcreatedX_addEXcreatedByX_toXaX() {
+ Traversal<Vertex, Edge> traversal = get_g_VX1X_asXaX_outXcreatedX_addEXcreatedByX_toXaX(convertToVertexId("marko"));
printTraversalForm(traversal);
int count = 0;
while (traversal.hasNext()) {
@@ -73,9 +110,31 @@ public abstract class AddEdgeTest extends AbstractGremlinProcessTest {
@Test
@LoadGraphWith(MODERN)
+ @Deprecated
@FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
public void g_VX1X_asXaX_outXcreatedX_addOutEXcreatedBy_a_weight_2X() {
- final Traversal<Vertex, Edge> traversal = get_g_VX1X_asXaX_outXcreatedX_addOutEXcreatedBy_a_weight_2X(convertToVertexId("marko"));
+ Traversal<Vertex, Edge> traversal = get_g_VX1X_asXaX_outXcreatedX_addOutEXcreatedBy_a_weight_2X(convertToVertexId("marko"));
+ printTraversalForm(traversal);
+ int count = 0;
+ while (traversal.hasNext()) {
+ final Edge edge = traversal.next();
+ assertEquals("createdBy", edge.label());
+ assertEquals(2, edge.<Integer>value("weight").intValue());
+ assertEquals(1, IteratorUtils.count(edge.properties()));
+ count++;
+
+
+ }
+ assertEquals(1, count);
+ assertEquals(7, IteratorUtils.count(graph.edges()));
+ assertEquals(6, IteratorUtils.count(graph.vertices()));
+ }
+
+ @Test
+ @LoadGraphWith(MODERN)
+ @FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
+ public void g_VX1X_asXaX_outXcreatedX_addEXcreatedByX_toXaX_propertyXweight_2X() {
+ Traversal<Vertex, Edge> traversal = get_g_VX1X_asXaX_outXcreatedX_addEXcreatedByX_toXaX_propertyXweight_2X(convertToVertexId("marko"));
printTraversalForm(traversal);
int count = 0;
while (traversal.hasNext()) {
@@ -93,9 +152,10 @@ public abstract class AddEdgeTest extends AbstractGremlinProcessTest {
}
@Test
+ @Ignore
@LoadGraphWith(MODERN)
@FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
- public void g_V_addOutEXexistsWith__g_V__time_nowX() {
+ public void g_withSideEffectXx__g_V_toListX_addOutEXexistsWith_x_time_nowX() {
final Traversal<Vertex, Edge> traversal = get_g_withSideEffectXx__g_V_toListX_addOutEXexistsWith_x_time_nowX();
printTraversalForm(traversal);
int count = 0;
@@ -117,6 +177,7 @@ public abstract class AddEdgeTest extends AbstractGremlinProcessTest {
@Test
@LoadGraphWith(MODERN)
+ @Deprecated
@FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
public void g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_selectXa_bX_addInEXa_codeveloper_b_year_2009X() {
final Traversal<Vertex, Edge> traversal = get_g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_selectXa_bX_addInEXa_codeveloper_b_year_2009X();
@@ -127,8 +188,33 @@ public abstract class AddEdgeTest extends AbstractGremlinProcessTest {
assertEquals("co-developer", edge.label());
assertEquals(2009, (int) edge.value("year"));
assertEquals(1, IteratorUtils.count(edge.properties()));
- assertEquals("person",edge.inVertex().label());
- assertEquals("person",edge.outVertex().label());
+ assertEquals("person", edge.inVertex().label());
+ assertEquals("person", edge.outVertex().label());
+ assertFalse(edge.inVertex().value("name").equals("vadas"));
+ assertFalse(edge.outVertex().value("name").equals("vadas"));
+ assertFalse(edge.inVertex().equals(edge.outVertex()));
+ count++;
+
+ }
+ assertEquals(6, count);
+ assertEquals(12, IteratorUtils.count(graph.edges()));
+ assertEquals(6, IteratorUtils.count(graph.vertices()));
+ }
+
+ @Test
+ @LoadGraphWith(MODERN)
+ @FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
+ public void g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_addEXcodeveloperX_fromXaX_toXbX_propertyXyear_2009X() {
+ final Traversal<Vertex, Edge> traversal = get_g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_addEXcodeveloperX_fromXaX_toXbX_propertyXyear_2009X();
+ printTraversalForm(traversal);
+ int count = 0;
+ while (traversal.hasNext()) {
+ final Edge edge = traversal.next();
+ assertEquals("co-developer", edge.label());
+ assertEquals(2009, (int) edge.value("year"));
+ assertEquals(1, IteratorUtils.count(edge.properties()));
+ assertEquals("person", edge.inVertex().label());
+ assertEquals("person", edge.outVertex().label());
assertFalse(edge.inVertex().value("name").equals("vadas"));
assertFalse(edge.outVertex().value("name").equals("vadas"));
assertFalse(edge.inVertex().equals(edge.outVertex()));
@@ -142,8 +228,9 @@ public abstract class AddEdgeTest extends AbstractGremlinProcessTest {
@Test
@LoadGraphWith(MODERN)
+ @Deprecated
@FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
- public void g_VXv1IdX_asXaX_inXcreatedX_addOutEXcreatedBy_a_year_2009_acl_publicX() {
+ public void g_V_asXaX_inXcreatedX_addInEXcreatedBy_a_year_2009_acl_publicX() {
final Traversal<Vertex, Edge> traversal = get_g_V_asXaX_inXcreatedX_addInEXcreatedBy_a_year_2009_acl_publicX();
printTraversalForm(traversal);
int count = 0;
@@ -153,10 +240,35 @@ public abstract class AddEdgeTest extends AbstractGremlinProcessTest {
assertEquals(2009, (int) edge.value("year"));
assertEquals("public", edge.value("acl"));
assertEquals(2, IteratorUtils.count(edge.properties()));
- assertEquals("person",edge.inVertex().label());
- assertEquals("software",edge.outVertex().label());
- if(edge.outVertex().value("name").equals("ripple"))
- assertEquals("josh",edge.inVertex().value("name"));
+ assertEquals("person", edge.inVertex().label());
+ assertEquals("software", edge.outVertex().label());
+ if (edge.outVertex().value("name").equals("ripple"))
+ assertEquals("josh", edge.inVertex().value("name"));
+ count++;
+
+ }
+ assertEquals(4, count);
+ assertEquals(10, IteratorUtils.count(graph.edges()));
+ assertEquals(6, IteratorUtils.count(graph.vertices()));
+ }
+
+ @Test
+ @LoadGraphWith(MODERN)
+ @FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
+ public void g_V_asXaX_inXcreatedX_addEXcreatedByX_fromXaX_propertyXyear_2009X_propertyXacl_publicX() {
+ final Traversal<Vertex, Edge> traversal = get_g_V_asXaX_inXcreatedX_addEXcreatedByX_fromXaX_propertyXyear_2009X_propertyXacl_publicX();
+ printTraversalForm(traversal);
+ int count = 0;
+ while (traversal.hasNext()) {
+ final Edge edge = traversal.next();
+ assertEquals("createdBy", edge.label());
+ assertEquals(2009, (int) edge.value("year"));
+ assertEquals("public", edge.value("acl"));
+ assertEquals(2, IteratorUtils.count(edge.properties()));
+ assertEquals("person", edge.inVertex().label());
+ assertEquals("software", edge.outVertex().label());
+ if (edge.outVertex().value("name").equals("ripple"))
+ assertEquals("josh", edge.inVertex().value("name"));
count++;
}
@@ -168,6 +280,33 @@ public abstract class AddEdgeTest extends AbstractGremlinProcessTest {
public static class Traversals extends AddEdgeTest {
@Override
+ public Traversal<Vertex, Edge> get_g_VX1X_asXaX_outXcreatedX_addEXcreatedByX_toXaX(final Object v1Id) {
+ return g.V(v1Id).as("a").out("created").addE("createdBy").to("a");
+ }
+
+ @Override
+ public Traversal<Vertex, Edge> get_g_VX1X_asXaX_outXcreatedX_addEXcreatedByX_toXaX_propertyXweight_2X(final Object v1Id) {
+ return g.V(v1Id).as("a").out("created").addE("createdBy").to("a").property("weight", 2);
+ }
+
+ /*@Override
+ public Traversal<Vertex, Edge> get_g_withSideEffectXx__g_V_toListX_addOutEXexistsWith_x_time_nowX() {
+ return g.withSideEffect("x", g.V().toList()).V().addE("existsWith").to(__.select("x")).property("time", "now");
+ }*/
+
+ @Override
+ public Traversal<Vertex, Edge> get_g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_addEXcodeveloperX_fromXaX_toXbX_propertyXyear_2009X() {
+ return g.V().as("a").out("created").in("created").where(P.neq("a")).as("b").addE("co-developer").from("a").to("b").property("year", 2009);
+ }
+
+ @Override
+ public Traversal<Vertex, Edge> get_g_V_asXaX_inXcreatedX_addEXcreatedByX_fromXaX_propertyXyear_2009X_propertyXacl_publicX() {
+ return g.V().as("a").in("created").addE("createdBy").from("a").property("year", 2009).property("acl", "public");
+ }
+
+ ///////
+
+ @Override
public Traversal<Vertex, Edge> get_g_VX1X_asXaX_outXcreatedX_addOutEXcreatedBy_aX(final Object v1Id) {
return g.V(v1Id).as("a").out("created").addOutE("createdBy", "a");
}
@@ -183,12 +322,12 @@ public abstract class AddEdgeTest extends AbstractGremlinProcessTest {
}
@Override
- public Traversal<Vertex,Edge> get_g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_selectXa_bX_addInEXa_codeveloper_b_year_2009X() {
- return g.V().as("a").out("created").in("created").where(P.neq("a")).as("b").select("a","b").addInE("a", "co-developer", "b", "year", 2009);
+ public Traversal<Vertex, Edge> get_g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_selectXa_bX_addInEXa_codeveloper_b_year_2009X() {
+ return g.V().as("a").out("created").in("created").where(P.neq("a")).as("b").select("a", "b").addInE("a", "co-developer", "b", "year", 2009);
}
@Override
- public Traversal<Vertex,Edge> get_g_V_asXaX_inXcreatedX_addInEXcreatedBy_a_year_2009_acl_publicX() {
+ public Traversal<Vertex, Edge> get_g_V_asXaX_inXcreatedX_addInEXcreatedBy_a_year_2009_acl_publicX() {
return g.V().as("a").in("created").addInE("createdBy", "a", "year", 2009, "acl", "public");
}
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java
----------------------------------------------------------------------
diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java
index bed5a7f..fad1519 100644
--- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java
+++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java
@@ -41,7 +41,7 @@ import static org.junit.Assert.assertFalse;
@RunWith(GremlinProcessRunner.class)
public abstract class AddVertexTest extends AbstractGremlinTest {
- public abstract Traversal<Vertex, Vertex> get_g_V_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX(final Object v1Id);
+ public abstract Traversal<Vertex, Vertex> get_g_VX1X_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX(final Object v1Id);
public abstract Traversal<Vertex, Vertex> get_g_V_addVXanimalX_propertyXage_0X();
@@ -58,7 +58,7 @@ public abstract class AddVertexTest extends AbstractGremlinTest {
@LoadGraphWith(MODERN)
@FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
public void g_V_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX() {
- final Traversal<Vertex, Vertex> traversal = get_g_V_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX(convertToVertexId(graph, "marko"));
+ final Traversal<Vertex, Vertex> traversal = get_g_VX1X_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX(convertToVertexId(graph, "marko"));
printTraversalForm(traversal);
final Vertex vertex = traversal.next();
assertEquals("animal", vertex.label());
@@ -139,7 +139,7 @@ public abstract class AddVertexTest extends AbstractGremlinTest {
public static class Traversals extends AddVertexTest {
@Override
- public Traversal<Vertex, Vertex> get_g_V_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX(final Object v1Id) {
+ public Traversal<Vertex, Vertex> get_g_VX1X_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX(final Object v1Id) {
return g.V(v1Id).as("a").addV("animal").property("age", __.select("a").by("age")).property("name", "puppy");
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyProcessTest.java
----------------------------------------------------------------------
diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyProcessTest.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyProcessTest.java
index 79e0a63..aeeb958 100644
--- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyProcessTest.java
+++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyProcessTest.java
@@ -155,7 +155,7 @@ public class ElementIdStrategyProcessTest extends AbstractGremlinProcessTest {
assertEquals("STEPHEN", sg.V("STEPHEN").id().next());
}*/
- @Test
+ /*@Test
@FeatureRequirementSet(FeatureRequirementSet.Package.SIMPLE)
public void shouldGenerateDefaultIdOnAddEWithSpecifiedId() throws Exception {
final ElementIdStrategy strategy = ElementIdStrategy.build().create();
@@ -202,7 +202,7 @@ public class ElementIdStrategyProcessTest extends AbstractGremlinProcessTest {
assertEquals("some-id", e.value("name"));
assertEquals("some-id", sg.E(e).id().next());
assertEquals("some-id", sg.E("some-id").id().next());
- }
+ } */
private GraphTraversalSource create(final ElementIdStrategy strategy) {
return graphProvider.traversal(graph, strategy);
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyProcessTest.java
----------------------------------------------------------------------
diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyProcessTest.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyProcessTest.java
index d38e1a8..979020b 100644
--- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyProcessTest.java
+++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyProcessTest.java
@@ -109,7 +109,7 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
v.addEdge("self", v);
final GraphTraversalSource gts = create(eventStrategy);
- gts.withSideEffect("v",()->v).V(v).addOutE("self", "v").next();
+ gts.V(v).as("v").addE("self").to("v").next();
tryCommit(graph, g -> assertEquals(2, IteratorUtils.count(gts.E())));
@@ -138,7 +138,7 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
v.addEdge("self", v);
final GraphTraversalSource gts = create(eventStrategy);
- gts.V(v).as("a").addOutE("self", "a").next();
+ gts.V(v).as("a").addE("self").to("a").next();
tryCommit(graph, g -> assertEquals(2, IteratorUtils.count(gts.E())));
@@ -172,8 +172,8 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
assertEquals(1, listener1.addVertexEventRecorded());
assertEquals(1, listener2.addVertexEventRecorded());
- assertEquals(1, listener2.vertexPropertyChangedEventRecorded());
- assertEquals(1, listener1.vertexPropertyChangedEventRecorded());
+ assertEquals(0, listener2.vertexPropertyChangedEventRecorded());
+ assertEquals(0, listener1.vertexPropertyChangedEventRecorded());
}
@Test
@@ -199,8 +199,8 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
assertEquals(1, listener1.addVertexEventRecorded());
assertEquals(1, listener2.addVertexEventRecorded());
- assertEquals(1, listener2.vertexPropertyChangedEventRecorded());
- assertEquals(1, listener1.vertexPropertyChangedEventRecorded());
+ assertEquals(0, listener2.vertexPropertyChangedEventRecorded());
+ assertEquals(0, listener1.vertexPropertyChangedEventRecorded());
}
@Test
@@ -278,7 +278,7 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
v.addEdge("self", v);
final GraphTraversalSource gts = create(eventStrategy);
- gts.withSideEffect("v",v).V(v).addOutE("self", "v").property("some", "thing").next();
+ gts.V(v).as("v").addE("self").to("v").property("some", "thing").next();
tryCommit(graph, g -> assertEquals(1, IteratorUtils.count(gts.E().has("some", "thing"))));
@@ -288,8 +288,8 @@ public class EventStrategyProcessTest extends AbstractGremlinProcessTest {
assertEquals(1, listener1.addEdgeEventRecorded());
assertEquals(1, listener2.addEdgeEventRecorded());
- assertEquals(1, listener2.edgePropertyChangedEventRecorded());
- assertEquals(1, listener1.edgePropertyChangedEventRecorded());
+ assertEquals(0, listener2.edgePropertyChangedEventRecorded());
+ assertEquals(0, listener1.edgePropertyChangedEventRecorded());
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyProcessTest.java
----------------------------------------------------------------------
diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyProcessTest.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyProcessTest.java
index 5bc2982..0debdae 100644
--- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyProcessTest.java
+++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyProcessTest.java
@@ -55,7 +55,7 @@ public class PartitionStrategyProcessTest extends AbstractGremlinProcessTest {
final GraphTraversalSource source = create(partitionStrategy);
final Vertex v1 = source.addV().property("any", "thing").next();
final Vertex v2 = source.addV().property("some", "thing").next();
- final Edge e = source.withSideEffect("v2", v2).V(v1.id()).addInE("connectsTo", "v2", "every", "thing").next();
+ final Edge e = source.withSideEffect("v2", v2).V(v1.id()).addE("connectsTo").from("v2").property("every", "thing").next();
assertNotNull(v1);
assertEquals("thing", v1.property("any").value());
@@ -143,7 +143,7 @@ public class PartitionStrategyProcessTest extends AbstractGremlinProcessTest {
final GraphTraversalSource sourceA = create(partitionStrategyA);
final Vertex vA = sourceAA.addV().property("any", "a").next();
- final Edge e = sourceAA.withSideEffect("vA", vA).V(vA.id()).addOutE("knows", "vA").next();
+ final Edge e = sourceAA.withSideEffect("vA", vA).V(vA.id()).addE("knows").to("vA").next();
assertEquals(e.id(), g.E(e.id()).id().next());
try {
@@ -196,14 +196,14 @@ public class PartitionStrategyProcessTest extends AbstractGremlinProcessTest {
final Vertex vA = sourceAA.addV().property("any", "a").next();
final Vertex vAA = sourceAA.addV().property("any", "aa").next();
- final Edge eAtoAA = sourceAA.withSideEffect("vAA", vAA).V(vA.id()).addOutE("a->a", "vAA").next();
+ final Edge eAtoAA = sourceAA.withSideEffect("vAA", vAA).V(vA.id()).addE("a->a").to("vAA").next();
final Vertex vB = sourceBA.addV().property("any", "b").next();
- sourceBA.withSideEffect("vB", vB).V(vA.id()).addOutE("a->b", "vB").next();
+ sourceBA.withSideEffect("vB", vB).V(vA.id()).addE("a->b").to("vB").next();
final Vertex vC = sourceCAB.addV().property("any", "c").next();
- final Edge eBtovC = sourceCAB.withSideEffect("vC", vC).V(vB.id()).addOutE("b->c", "vC").next();
- final Edge eAtovC = sourceCAB.withSideEffect("vC", vC).V(vA.id()).addOutE("a->c", "vC").next();
+ final Edge eBtovC = sourceCAB.withSideEffect("vC", vC).V(vB.id()).addE("b->c").to("vC").next();
+ final Edge eAtovC = sourceCAB.withSideEffect("vC", vC).V(vA.id()).addE("a->c").to("vC").next();
assertEquals(0, IteratorUtils.count(sourceC.V()));
assertEquals(0, IteratorUtils.count(sourceC.E()));
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyProcessTest.java
----------------------------------------------------------------------
diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyProcessTest.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyProcessTest.java
index aba26fb..73eeae3 100644
--- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyProcessTest.java
+++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyProcessTest.java
@@ -62,37 +62,37 @@ public class ReadOnlyStrategyProcessTest extends AbstractGremlinProcessTest {
@Test
@FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
public void shouldNotTraverseV_out_addInE() {
- assertTraversal(create().V().as("a").out().addInE("test", "a"), true);
+ assertTraversal(create().V().as("a").out().addE("test").from("a"), true);
}
@Test
@FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
public void shouldNotTraverseV_out_addOutE() {
- assertTraversal(create().V().as("a").out().addOutE("test", "a"), true);
+ assertTraversal(create().V().as("a").out().addE("test").to("a"), true);
}
@Test
@FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
public void shouldNotTraverseV_In_addInE() {
- assertTraversal(create().V().as("a").in().addInE("test", "a"), true);
+ assertTraversal(create().V().as("a").in().addE("test").from("a"), true);
}
@Test
@FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
public void shouldNotTraverseV_In_addOutE() {
- assertTraversal(create().V().as("a").in().addOutE("test", "a"), true);
+ assertTraversal(create().V().as("a").in().addE("test").to("a"), true);
}
@Test
@FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
public void shouldNotTraverseV_In_addEXINX() {
- assertTraversal(create().V().as("a").in().addE(Direction.IN, "test", "a"), true);
+ assertTraversal(create().V().as("a").in().addE("test").from("a"), true);
}
@Test
@FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
public void shouldNotTraverseV_In_addEXOUTX() {
- assertTraversal(create().V().as("a").in().addE(Direction.OUT, "test", "a"), true);
+ assertTraversal(create().V().as("a").in().addE("test").to("a"), true);
}
private GraphTraversalSource create() {
[3/8] incubator-tinkerpop git commit: New mutation model that is
backwards compatible (though Deprecation) with old mutation model.
Posted by ok...@apache.org.
New mutation model that is backwards compatible (though Deprecation) with old mutation model.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/f314fe67
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/f314fe67
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/f314fe67
Branch: refs/heads/master
Commit: f314fe6740c8a1a7c04b980fac63e0a77b65f547
Parents: 6ffcca3
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Tue Aug 25 16:15:39 2015 -0600
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Tue Aug 25 16:15:39 2015 -0600
----------------------------------------------------------------------
.../process/traversal/Parameterizing.java | 32 ++++
.../traversal/dsl/graph/GraphTraversal.java | 90 ++++++++--
.../gremlin/process/traversal/dsl/graph/__.java | 10 ++
.../process/traversal/step/Mutating.java | 4 +-
.../process/traversal/step/filter/DropStep.java | 4 +
.../process/traversal/step/map/AddEdgeStep.java | 106 +++++-------
.../traversal/step/map/AddVertexStartStep.java | 46 +++--
.../traversal/step/map/AddVertexStep.java | 14 +-
.../step/sideEffect/AddPropertyStep.java | 14 +-
.../process/traversal/step/util/Parameters.java | 32 +++-
.../strategy/decoration/ElementIdStrategy.java | 45 ++---
.../strategy/decoration/PartitionStrategy.java | 30 +---
.../traversal/dsl/graph/GraphTraversalTest.java | 2 +-
.../traversal/step/map/AddEdgeStepTest.java | 10 +-
.../ElementIdStrategyTraverseTest.java | 38 ++---
.../strategy/decoration/EventStrategyTest.java | 17 +-
.../PartitionStrategyTraverseTest.java | 64 ++-----
.../SubgraphStrategyTraverseTest.java | 20 +--
.../verification/ReadOnlyStrategyTest.java | 15 +-
.../traversal/step/map/GroovyAddEdgeTest.groovy | 26 +++
.../step/map/GroovyAddVertexTest.groovy | 10 +-
.../process/traversal/step/map/AddEdgeTest.java | 171 +++++++++++++++++--
.../traversal/step/map/AddVertexTest.java | 6 +-
.../ElementIdStrategyProcessTest.java | 4 +-
.../decoration/EventStrategyProcessTest.java | 18 +-
.../PartitionStrategyProcessTest.java | 12 +-
.../ReadOnlyStrategyProcessTest.java | 12 +-
27 files changed, 523 insertions(+), 329 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/Parameterizing.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/Parameterizing.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/Parameterizing.java
new file mode 100644
index 0000000..b3249bf
--- /dev/null
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/Parameterizing.java
@@ -0,0 +1,32 @@
+/*
+ *
+ * * Licensed to the Apache Software Foundation (ASF) under one
+ * * or more contributor license agreements. See the NOTICE file
+ * * distributed with this work for additional information
+ * * regarding copyright ownership. The ASF licenses this file
+ * * to you under the Apache License, Version 2.0 (the
+ * * "License"); you may not use this file except in compliance
+ * * with the License. You may obtain a copy of the License at
+ * *
+ * * http://www.apache.org/licenses/LICENSE-2.0
+ * *
+ * * Unless required by applicable law or agreed to in writing,
+ * * software distributed under the License is distributed on an
+ * * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * * KIND, either express or implied. See the License for the
+ * * specific language governing permissions and limitations
+ * * under the License.
+ *
+ */
+
+package org.apache.tinkerpop.gremlin.process.traversal;
+
+import org.apache.tinkerpop.gremlin.process.traversal.step.util.Parameters;
+
+/**
+ * @author Marko A. Rodriguez (http://markorodriguez.com)
+ */
+public interface Parameterizing {
+
+ public Parameters getParameters();
+}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
index 043882c..2fdb3e2 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
@@ -62,6 +62,7 @@ import org.apache.tinkerpop.gremlin.process.traversal.step.filter.TraversalFilte
import org.apache.tinkerpop.gremlin.process.traversal.step.filter.WherePredicateStep;
import org.apache.tinkerpop.gremlin.process.traversal.step.filter.WhereTraversalStep;
import org.apache.tinkerpop.gremlin.process.traversal.step.map.AddEdgeStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.map.AddVertexStartStep;
import org.apache.tinkerpop.gremlin.process.traversal.step.map.AddVertexStep;
import org.apache.tinkerpop.gremlin.process.traversal.step.map.CoalesceStep;
import org.apache.tinkerpop.gremlin.process.traversal.step.map.ConstantStep;
@@ -138,7 +139,6 @@ import org.apache.tinkerpop.gremlin.structure.PropertyType;
import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.apache.tinkerpop.gremlin.structure.VertexProperty;
-import org.apache.tinkerpop.gremlin.structure.util.ElementHelper;
import org.apache.tinkerpop.gremlin.util.function.ConstantSupplier;
import java.util.Arrays;
@@ -645,24 +645,82 @@ public interface GraphTraversal<S, E> extends Traversal<S, E> {
return this.asAdmin().addStep(new AddVertexStep<>(this.asAdmin(), null));
}
+ /**
+ * @deprecated As of release 3.1.0, replaced by {@link #addV()}
+ */
@Deprecated
public default GraphTraversal<S, Vertex> addV(final Object... propertyKeyValues) {
- this.addV(ElementHelper.getLabelValue(propertyKeyValues).orElse(Vertex.DEFAULT_LABEL));
+ this.addV();
((AddVertexStep) this.asAdmin().getEndStep()).addPropertyMutations(propertyKeyValues);
return (GraphTraversal<S, Vertex>) this;
}
+ public default GraphTraversal<S, Edge> addE(final String edgeLabel) {
+ return this.asAdmin().addStep(new AddEdgeStep<>(this.asAdmin(), edgeLabel));
+ }
+
+ public default GraphTraversal<S, E> to(final String toStepLabel) {
+ return this.to(__.select(toStepLabel));
+ }
+
+ public default GraphTraversal<S, E> from(final String fromStepLabel) {
+ return this.from(__.select(fromStepLabel));
+ }
+
+ public default GraphTraversal<S, E> to(final Traversal<E, Vertex> toVertex) {
+ ((AddEdgeStep) this.asAdmin().getEndStep()).addTo(toVertex);
+ return this;
+ }
+
+ public default GraphTraversal<S, E> from(final Traversal<E, Vertex> fromVertex) {
+ ((AddEdgeStep) this.asAdmin().getEndStep()).addFrom(fromVertex);
+ return this;
+ }
+
+ public default GraphTraversal<S, E> id(final Object elementId) {
+ ((Mutating) this.asAdmin().getEndStep()).addPropertyMutations(T.id, elementId);
+ return this;
+ }
+
+ /**
+ * @deprecated As of release 3.1.0, replaced by {@link #addE(String)}
+ */
+ @Deprecated
public default GraphTraversal<S, Edge> addE(final Direction direction, final String firstVertexKeyOrEdgeLabel, final String edgeLabelOrSecondVertexKey, final Object... propertyKeyValues) {
- if (propertyKeyValues.length % 2 == 0)
- return this.asAdmin().addStep(new AddEdgeStep<>(this.asAdmin(), direction, null, firstVertexKeyOrEdgeLabel, edgeLabelOrSecondVertexKey, propertyKeyValues));
- else
- return this.asAdmin().addStep(new AddEdgeStep<>(this.asAdmin(), direction, firstVertexKeyOrEdgeLabel, edgeLabelOrSecondVertexKey, (String) propertyKeyValues[0], Arrays.copyOfRange(propertyKeyValues, 1, propertyKeyValues.length)));
+
+ if (propertyKeyValues.length % 2 == 0) {
+ // addOutE("createdBy", "a")
+ this.addE(firstVertexKeyOrEdgeLabel);
+ if (direction.equals(Direction.OUT))
+ this.to(edgeLabelOrSecondVertexKey);
+ else
+ this.from(edgeLabelOrSecondVertexKey);
+ ((Mutating) this.asAdmin().getEndStep()).addPropertyMutations(propertyKeyValues);
+ return (GraphTraversal<S, Edge>) this;
+ } else {
+ // addInE("a", "co-developer", "b", "year", 2009)
+ this.addE(edgeLabelOrSecondVertexKey);
+ if (direction.equals(Direction.OUT))
+ this.from(firstVertexKeyOrEdgeLabel).to((String) propertyKeyValues[0]);
+ else
+ this.to(firstVertexKeyOrEdgeLabel).from((String) propertyKeyValues[0]);
+ ((Mutating) this.asAdmin().getEndStep()).addPropertyMutations(Arrays.copyOfRange(propertyKeyValues, 1, propertyKeyValues.length));
+ return (GraphTraversal<S, Edge>) this;
+ }
}
+ /**
+ * @deprecated As of release 3.1.0, replaced by {@link #addE(String)}
+ */
+ @Deprecated
public default GraphTraversal<S, Edge> addOutE(final String firstVertexKeyOrEdgeLabel, final String edgeLabelOrSecondVertexKey, final Object... propertyKeyValues) {
return this.addE(Direction.OUT, firstVertexKeyOrEdgeLabel, edgeLabelOrSecondVertexKey, propertyKeyValues);
}
+ /**
+ * @deprecated As of release 3.1.0, replaced by {@link #addE(String)}
+ */
+ @Deprecated
public default GraphTraversal<S, Edge> addInE(final String firstVertexKeyOrEdgeLabel, final String edgeLabelOrSecondVertexKey, final Object... propertyKeyValues) {
return this.addE(Direction.IN, firstVertexKeyOrEdgeLabel, edgeLabelOrSecondVertexKey, propertyKeyValues);
}
@@ -920,7 +978,8 @@ public interface GraphTraversal<S, E> extends Traversal<S, E> {
return this.asAdmin().addStep(new SackObjectStep<>(this.asAdmin(), sackFunction));
}
- public default <V> GraphTraversal<S, E> sack(final BinaryOperator<V> sackOperator, final String elementPropertyKey) {
+ public default <V> GraphTraversal<S, E> sack(final BinaryOperator<V> sackOperator,
+ final String elementPropertyKey) {
return this.asAdmin().addStep(new SackElementValueStep(this.asAdmin(), sackOperator, elementPropertyKey));
}
@@ -933,8 +992,9 @@ public interface GraphTraversal<S, E> extends Traversal<S, E> {
}
- public default GraphTraversal<S, E> property(final VertexProperty.Cardinality cardinality, final Object key, final Object value, final Object... keyValues) {
- if ((this.asAdmin().getEndStep() instanceof AddVertexStep || this.asAdmin().getEndStep() instanceof AddEdgeStep) && keyValues.length == 0) {
+ public default GraphTraversal<S, E> property(final VertexProperty.Cardinality cardinality, final Object key,
+ final Object value, final Object... keyValues) {
+ if ((this.asAdmin().getEndStep() instanceof AddVertexStep || this.asAdmin().getEndStep() instanceof AddEdgeStep || this.asAdmin().getEndStep() instanceof AddVertexStartStep) && keyValues.length == 0) {
((Mutating) this.asAdmin().getEndStep()).addPropertyMutations(new Object[]{key, value});
} else {
this.asAdmin().addStep(new AddPropertyStep(this.asAdmin(), cardinality, key, value));
@@ -963,7 +1023,8 @@ public interface GraphTraversal<S, E> extends Traversal<S, E> {
return this.asAdmin().addStep(new ChooseStep<>(this.asAdmin(), (Traversal.Admin<E, M>) choiceTraversal));
}
- public default <E2> GraphTraversal<S, E2> choose(final Traversal<?, ?> traversalPredicate, final Traversal<?, E2> trueChoice, final Traversal<?, E2> falseChoice) {
+ public default <E2> GraphTraversal<S, E2> choose(final Traversal<?, ?> traversalPredicate,
+ final Traversal<?, E2> trueChoice, final Traversal<?, E2> falseChoice) {
return this.asAdmin().addStep(new ChooseStep<E, E2, Boolean>(this.asAdmin(), (Traversal.Admin<E, ?>) traversalPredicate, (Traversal.Admin<E, E2>) trueChoice, (Traversal.Admin<E, E2>) falseChoice));
}
@@ -971,7 +1032,8 @@ public interface GraphTraversal<S, E> extends Traversal<S, E> {
return this.choose(__.map(new FunctionTraverser<>(choiceFunction)));
}
- public default <E2> GraphTraversal<S, E2> choose(final Predicate<E> choosePredicate, final Traversal<?, E2> trueChoice, final Traversal<?, E2> falseChoice) {
+ public default <E2> GraphTraversal<S, E2> choose(final Predicate<E> choosePredicate,
+ final Traversal<?, E2> trueChoice, final Traversal<?, E2> falseChoice) {
return this.choose(__.filter(new PredicateTraverser<>(choosePredicate)), trueChoice, falseChoice);
}
@@ -1069,11 +1131,13 @@ public interface GraphTraversal<S, E> extends Traversal<S, E> {
return this.by((Comparator) order);
}
- public default <V> GraphTraversal<S, E> by(final Function<Element, V> elementFunctionProjection, final Comparator<V> elementFunctionValueComparator) {
+ public default <V> GraphTraversal<S, E> by(final Function<Element, V> elementFunctionProjection,
+ final Comparator<V> elementFunctionValueComparator) {
return this.by((Comparator) new ElementFunctionComparator<>(elementFunctionProjection, elementFunctionValueComparator));
}
- public default <V> GraphTraversal<S, E> by(final String elementPropertyProjection, final Comparator<V> propertyValueComparator) {
+ public default <V> GraphTraversal<S, E> by(final String elementPropertyProjection,
+ final Comparator<V> propertyValueComparator) {
return this.by((Comparator) new ElementValueComparator<>(elementPropertyProjection, propertyValueComparator));
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/__.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/__.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/__.java
index b20e4a9..d3fc107 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/__.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/__.java
@@ -472,6 +472,7 @@ public class __ {
/**
* @see {@link GraphTraversal#addE(Direction, String, String, Object...)}
*/
+ @Deprecated
public static <A> GraphTraversal<A, Edge> addE(final Direction direction, final String firstVertexKeyOrEdgeLabel, final String edgeLabelOrSecondVertexKey, final Object... propertyKeyValues) {
return __.<A>start().addE(direction, firstVertexKeyOrEdgeLabel, edgeLabelOrSecondVertexKey, propertyKeyValues);
}
@@ -479,6 +480,7 @@ public class __ {
/**
* @see {@link GraphTraversal#addOutE(String, String, Object...)}
*/
+ @Deprecated
public static <A> GraphTraversal<A, Edge> addOutE(final String firstVertexKeyOrEdgeLabel, final String edgeLabelOrSecondVertexKey, final Object... propertyKeyValues) {
return __.<A>start().addOutE(firstVertexKeyOrEdgeLabel, edgeLabelOrSecondVertexKey, propertyKeyValues);
}
@@ -486,10 +488,18 @@ public class __ {
/**
* @see {@link GraphTraversal#addInE(String, String, Object...)}
*/
+ @Deprecated
public static <A> GraphTraversal<A, Edge> addInE(final String firstVertexKeyOrEdgeLabel, final String edgeLabelOrSecondVertexKey, final Object... propertyKeyValues) {
return __.<A>start().addInE(firstVertexKeyOrEdgeLabel, edgeLabelOrSecondVertexKey, propertyKeyValues);
}
+ /**
+ * @see {@link GraphTraversal#addE(String)}
+ */
+ public static <A> GraphTraversal<A, Edge> addE(final String edgeLabel) {
+ return __.<A>start().addE(edgeLabel);
+ }
+
///////////////////// FILTER STEPS /////////////////////
public static <A> GraphTraversal<A, A> filter(final Predicate<Traverser<A>> predicate) {
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/Mutating.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/Mutating.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/Mutating.java
index 17d8e09..50e415a 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/Mutating.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/Mutating.java
@@ -35,8 +35,6 @@ public interface Mutating<E extends Event> {
*/
public CallbackRegistry<E> getMutatingCallbackRegistry();
- public default void addPropertyMutations(final Object... keyValues) {
-
- }
+ public void addPropertyMutations(final Object... keyValues);
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/filter/DropStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/filter/DropStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/filter/DropStep.java
index c53540c..cb9272c 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/filter/DropStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/filter/DropStep.java
@@ -87,4 +87,8 @@ public final class DropStep<S> extends FilterStep<S> implements Mutating<Event>
if (null == callbackRegistry) callbackRegistry = new ListCallbackRegistry<>();
return callbackRegistry;
}
+
+ public void addPropertyMutations(final Object... keyValues) {
+
+ }
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java
index c7fa153..dbd6491 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java
@@ -18,93 +18,80 @@
*/
package org.apache.tinkerpop.gremlin.process.traversal.step.map;
-import org.apache.tinkerpop.gremlin.process.traversal.Pop;
+import org.apache.tinkerpop.gremlin.process.traversal.Parameterizing;
import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
import org.apache.tinkerpop.gremlin.process.traversal.Traverser;
import org.apache.tinkerpop.gremlin.process.traversal.step.Mutating;
-import org.apache.tinkerpop.gremlin.process.traversal.step.Scoping;
+import org.apache.tinkerpop.gremlin.process.traversal.step.TraversalParent;
+import org.apache.tinkerpop.gremlin.process.traversal.step.util.Parameters;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.CallbackRegistry;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.Event;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.ListCallbackRegistry;
import org.apache.tinkerpop.gremlin.process.traversal.traverser.TraverserRequirement;
-import org.apache.tinkerpop.gremlin.process.traversal.util.TraversalHelper;
-import org.apache.tinkerpop.gremlin.structure.Direction;
import org.apache.tinkerpop.gremlin.structure.Edge;
+import org.apache.tinkerpop.gremlin.structure.Graph;
+import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
+import org.apache.tinkerpop.gremlin.structure.util.StringFactory;
import org.apache.tinkerpop.gremlin.structure.util.detached.DetachedFactory;
import org.apache.tinkerpop.gremlin.util.iterator.IteratorUtils;
-import java.util.HashSet;
import java.util.Iterator;
+import java.util.List;
import java.util.Set;
/**
* @author Marko A. Rodriguez (http://markorodriguez.com)
* @author Stephen Mallette (http://stephen.genoprime.com)
*/
-public final class AddEdgeStep<S> extends FlatMapStep<S, Edge> implements Scoping, Mutating<Event.EdgeAddedEvent> {
+public final class AddEdgeStep<S> extends FlatMapStep<S, Edge> implements Mutating<Event.EdgeAddedEvent>, TraversalParent, Parameterizing {
- private final Direction direction;
- private final String firstVertexKey;
- private final String edgeLabel;
- private final String secondVertexKey;
- private final Object[] propertyKeyValues;
+ private static final String FROM = Graph.Hidden.hide("from");
+ private static final String TO = Graph.Hidden.hide("to");
+ private final Parameters parameters = new Parameters();
private CallbackRegistry<Event.EdgeAddedEvent> callbackRegistry;
- public AddEdgeStep(final Traversal.Admin traversal, final Direction direction, final String firstVertexKey, final String edgeLabel, final String secondVertexKey, final Object... propertyKeyValues) {
+ public AddEdgeStep(final Traversal.Admin traversal, final String edgeLabel) {
super(traversal);
- this.direction = direction;
- this.firstVertexKey = firstVertexKey;
- this.edgeLabel = edgeLabel;
- this.secondVertexKey = secondVertexKey;
- this.propertyKeyValues = propertyKeyValues;
+ this.parameters.set(T.label, edgeLabel);
}
- public Direction getDirection() {
- return this.direction;
+ @Override
+ public <S, E> List<Traversal.Admin<S, E>> getLocalChildren() {
+ return this.parameters.getTraversals();
}
- public String getFirstVertexKey() {
- return this.firstVertexKey;
+ @Override
+ public Parameters getParameters() {
+ return this.parameters;
}
- public String getEdgeLabel() {
- return this.edgeLabel;
+ @Override
+ public void addPropertyMutations(final Object... keyValues) {
+ for (int i = 0; i < keyValues.length; i = i + 2) {
+ this.parameters.set(keyValues[i], keyValues[i + 1]);
+ }
+ this.parameters.integrateTraversals(this);
}
- public String getSecondVertexKey() {
- return this.secondVertexKey;
+ public void addTo(final Object toObject) {
+ this.parameters.set(TO, toObject);
+ this.parameters.integrateTraversals(this);
}
- public Object[] getPropertyKeyValues() {
- return this.propertyKeyValues;
+ public void addFrom(final Object fromObject) {
+ this.parameters.set(FROM, fromObject);
+ this.parameters.integrateTraversals(this);
}
@Override
protected Iterator<Edge> flatMap(final Traverser.Admin<S> traverser) {
- final Object firstVertex = null == this.firstVertexKey ? (Vertex) traverser.get() : this.getScopeValue(Pop.last, this.firstVertexKey, traverser);
- final Object secondVertex = null == this.secondVertexKey ? (Vertex) traverser.get() : this.getScopeValue(Pop.last, this.secondVertexKey, traverser);
- final Object finalFirstVertex = firstVertex instanceof Iterable ? ((Iterable) firstVertex).iterator() : firstVertex;
- final Object finalSecondVertex = secondVertex instanceof Iterable ? ((Iterable) secondVertex).iterator() : secondVertex;
-
- final Iterator<Edge> edgeIterator;
- if (finalFirstVertex instanceof Iterator) {
- edgeIterator = IteratorUtils.map((Iterator<Vertex>) finalFirstVertex, vertex ->
- this.direction.equals(Direction.OUT) ?
- vertex.addEdge(this.edgeLabel, (Vertex) finalSecondVertex, this.propertyKeyValues) :
- ((Vertex) finalSecondVertex).addEdge(this.edgeLabel, vertex, this.propertyKeyValues));
- } else if (finalSecondVertex instanceof Iterator) {
- edgeIterator = IteratorUtils.map((Iterator<Vertex>) finalSecondVertex, vertex ->
- this.direction.equals(Direction.OUT) ?
- ((Vertex) finalFirstVertex).addEdge(this.edgeLabel, vertex, this.propertyKeyValues) :
- vertex.addEdge(this.edgeLabel, ((Vertex) finalFirstVertex), this.propertyKeyValues));
- } else {
- edgeIterator = IteratorUtils.of(this.direction.equals(Direction.OUT) ?
- ((Vertex) firstVertex).addEdge(this.edgeLabel, (Vertex) secondVertex, this.propertyKeyValues) :
- ((Vertex) secondVertex).addEdge(this.edgeLabel, (Vertex) firstVertex, this.propertyKeyValues));
- }
+ final Vertex toVertex = this.parameters.get(traverser, TO, () -> (Vertex) traverser.get());
+ final Vertex fromVertex = this.parameters.get(traverser, FROM, () -> (Vertex) traverser.get());
+ final String edgeLabel = this.parameters.get(traverser, T.label, () -> Edge.DEFAULT_LABEL);
+ final Iterator<Edge> edgeIterator = IteratorUtils.of(fromVertex.addEdge(edgeLabel, toVertex, this.parameters.getKeyValues(traverser, TO, FROM, T.label)));
return IteratorUtils.consume(edgeIterator, edge -> {
if (callbackRegistry != null) {
final Event.EdgeAddedEvent vae = new Event.EdgeAddedEvent(DetachedFactory.detach(edge, true));
@@ -115,9 +102,7 @@ public final class AddEdgeStep<S> extends FlatMapStep<S, Edge> implements Scopin
@Override
public Set<TraverserRequirement> getRequirements() {
- return TraversalHelper.getLabels(TraversalHelper.getRootTraversal(this.traversal)).stream().filter(this.getScopeKeys()::contains).findAny().isPresent() ?
- TYPICAL_GLOBAL_REQUIREMENTS :
- TYPICAL_LOCAL_REQUIREMENTS;
+ return this.getSelfAndChildRequirements(TraverserRequirement.OBJECT);
}
@Override
@@ -128,24 +113,13 @@ public final class AddEdgeStep<S> extends FlatMapStep<S, Edge> implements Scopin
@Override
public int hashCode() {
- int result = super.hashCode() ^ this.direction.hashCode() ^ this.edgeLabel.hashCode();
- if (null != this.firstVertexKey)
- result ^= this.firstVertexKey.hashCode();
- if (null != this.secondVertexKey)
- result ^= this.secondVertexKey.hashCode();
- for (final Object object : this.propertyKeyValues) {
- result ^= object.hashCode();
- }
+ int result = super.hashCode() ^ this.parameters.hashCode();
return result;
}
@Override
- public Set<String> getScopeKeys() {
- final Set<String> keys = new HashSet<>();
- if (null != this.firstVertexKey)
- keys.add(this.firstVertexKey);
- if (null != this.secondVertexKey)
- keys.add(this.secondVertexKey);
- return keys;
+ public String toString() {
+ return StringFactory.stepString(this, this.parameters.toString());
}
+
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java
index e63fd8c..da5cf71 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStartStep.java
@@ -18,54 +18,65 @@
*/
package org.apache.tinkerpop.gremlin.process.traversal.step.map;
+import org.apache.tinkerpop.gremlin.process.traversal.Parameterizing;
import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
import org.apache.tinkerpop.gremlin.process.traversal.Traverser;
import org.apache.tinkerpop.gremlin.process.traversal.step.Mutating;
+import org.apache.tinkerpop.gremlin.process.traversal.step.TraversalParent;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.AbstractStep;
+import org.apache.tinkerpop.gremlin.process.traversal.step.util.Parameters;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.CallbackRegistry;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.Event;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.ListCallbackRegistry;
+import org.apache.tinkerpop.gremlin.process.traversal.traverser.TraverserRequirement;
+import org.apache.tinkerpop.gremlin.process.traversal.traverser.util.EmptyTraverser;
import org.apache.tinkerpop.gremlin.process.traversal.util.FastNoSuchElementException;
import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.apache.tinkerpop.gremlin.structure.util.detached.DetachedFactory;
-import java.util.ArrayList;
-import java.util.Collections;
import java.util.List;
+import java.util.Set;
/**
* @author Marko A. Rodriguez (http://markorodriguez.com)
* @author Stephen Mallette (http://stephen.genoprime.com)
*/
-public final class AddVertexStartStep extends AbstractStep<Vertex, Vertex> implements Mutating<Event.VertexAddedEvent> {
+public final class AddVertexStartStep extends AbstractStep<Vertex, Vertex> implements Mutating<Event.VertexAddedEvent>, TraversalParent, Parameterizing {
- private List<Object> keyValues = new ArrayList<>();
+ private final Parameters parameters = new Parameters();
private boolean first = true;
private CallbackRegistry<Event.VertexAddedEvent> callbackRegistry;
public AddVertexStartStep(final Traversal.Admin traversal, final String label) {
super(traversal);
- if (null != label) {
- this.keyValues.add(T.label);
- this.keyValues.add(label);
- }
+ this.parameters.set(T.label, label);
+ this.parameters.integrateTraversals(this);
}
- public Object[] getKeyValues() {
- return keyValues.toArray(new Object[this.keyValues.size()]);
+ @Override
+ public Parameters getParameters() {
+ return this.parameters;
+ }
+
+ @Override
+ public <S, E> List<Traversal.Admin<S, E>> getLocalChildren() {
+ return this.parameters.getTraversals();
}
@Override
public void addPropertyMutations(final Object... keyValues) {
- Collections.addAll(this.keyValues, keyValues);
+ for (int i = 0; i < keyValues.length; i = i + 2) {
+ this.parameters.set(keyValues[i], keyValues[i + 1]);
+ }
+ this.parameters.integrateTraversals(this);
}
@Override
protected Traverser<Vertex> processNextStart() {
if (this.first) {
this.first = false;
- final Vertex v = this.getTraversal().getGraph().get().addVertex(this.keyValues.toArray(new Object[this.keyValues.size()]));
+ final Vertex v = this.getTraversal().getGraph().get().addVertex(this.parameters.getKeyValues(EmptyTraverser.instance()));
if (callbackRegistry != null) {
final Event.VertexAddedEvent vae = new Event.VertexAddedEvent(DetachedFactory.detach(v, true));
callbackRegistry.getCallbacks().forEach(c -> c.accept(vae));
@@ -83,12 +94,13 @@ public final class AddVertexStartStep extends AbstractStep<Vertex, Vertex> imple
}
@Override
+ public Set<TraverserRequirement> getRequirements() {
+ return this.getSelfAndChildRequirements();
+ }
+
+ @Override
public int hashCode() {
- int result = super.hashCode();
- for (final Object item : this.keyValues) {
- result ^= item.hashCode();
- }
- return result;
+ return super.hashCode() ^ this.parameters.hashCode();
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java
index 77c4786..2e813f8 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexStep.java
@@ -18,6 +18,7 @@
*/
package org.apache.tinkerpop.gremlin.process.traversal.step.map;
+import org.apache.tinkerpop.gremlin.process.traversal.Parameterizing;
import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
import org.apache.tinkerpop.gremlin.process.traversal.Traverser;
import org.apache.tinkerpop.gremlin.process.traversal.step.Mutating;
@@ -27,7 +28,6 @@ import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.CallbackRe
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.Event;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.event.ListCallbackRegistry;
import org.apache.tinkerpop.gremlin.process.traversal.traverser.TraverserRequirement;
-import org.apache.tinkerpop.gremlin.process.traversal.traverser.util.EmptyTraverser;
import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.apache.tinkerpop.gremlin.structure.util.detached.DetachedFactory;
@@ -39,7 +39,7 @@ import java.util.Set;
* @author Marko A. Rodriguez (http://markorodriguez.com)
* @author Stephen Mallette (http://stephen.genoprime.com)
*/
-public final class AddVertexStep<S> extends MapStep<S, Vertex> implements Mutating<Event.VertexAddedEvent>, TraversalParent {
+public final class AddVertexStep<S> extends MapStep<S, Vertex> implements Mutating<Event.VertexAddedEvent>, TraversalParent, Parameterizing {
private final Parameters parameters = new Parameters();
private CallbackRegistry<Event.VertexAddedEvent> callbackRegistry;
@@ -51,13 +51,13 @@ public final class AddVertexStep<S> extends MapStep<S, Vertex> implements Mutati
}
@Override
- public <S, E> List<Traversal.Admin<S, E>> getLocalChildren() {
- return this.parameters.getTraversals();
+ public Parameters getParameters() {
+ return this.parameters;
}
-
- public Object[] getKeyValues() {
- return this.parameters.getKeyValues(EmptyTraverser.instance());
+ @Override
+ public <S, E> List<Traversal.Admin<S, E>> getLocalChildren() {
+ return this.parameters.getTraversals();
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
index 9176b15..d6771ae 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
@@ -18,6 +18,7 @@
*/
package org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect;
+import org.apache.tinkerpop.gremlin.process.traversal.Parameterizing;
import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
import org.apache.tinkerpop.gremlin.process.traversal.Traverser;
import org.apache.tinkerpop.gremlin.process.traversal.step.Mutating;
@@ -41,7 +42,7 @@ import java.util.Set;
/**
* @author Marko A. Rodriguez (http://markorodriguez.com)
*/
-public final class AddPropertyStep<S extends Element> extends SideEffectStep<S> implements Mutating<Event.ElementPropertyChangedEvent>, TraversalParent {
+public final class AddPropertyStep<S extends Element> extends SideEffectStep<S> implements Mutating<Event.ElementPropertyChangedEvent>, TraversalParent, Parameterizing {
private final Parameters parameters = new Parameters();
@@ -57,6 +58,11 @@ public final class AddPropertyStep<S extends Element> extends SideEffectStep<S>
}
@Override
+ public Parameters getParameters() {
+ return this.parameters;
+ }
+
+ @Override
public <S, E> List<Traversal.Admin<S, E>> getLocalChildren() {
return this.parameters.getTraversals();
}
@@ -71,8 +77,8 @@ public final class AddPropertyStep<S extends Element> extends SideEffectStep<S>
@Override
protected void sideEffect(final Traverser.Admin<S> traverser) {
- final String key = this.parameters.get(traverser, T.key);
- final Object value = this.parameters.get(traverser, T.value);
+ final String key = this.parameters.get(traverser, T.key, null);
+ final Object value = this.parameters.get(traverser, T.value, null);
final Object[] vertexPropertyKeyValues = this.parameters.getKeyValues(traverser, T.key, T.value);
if (this.callbackRegistry != null) {
@@ -116,7 +122,7 @@ public final class AddPropertyStep<S extends Element> extends SideEffectStep<S>
@Override
public int hashCode() {
- return super.hashCode() ^ this.cardinality.hashCode() ^ this.parameters.hashCode();
+ return super.hashCode() ^ this.parameters.hashCode() ^ ((null == this.cardinality) ? "null".hashCode() : this.cardinality.hashCode());
}
// TODO clone()
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/util/Parameters.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/util/Parameters.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/util/Parameters.java
index 3a20c8d..55f814f 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/util/Parameters.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/util/Parameters.java
@@ -27,10 +27,12 @@ import org.apache.tinkerpop.gremlin.process.traversal.step.TraversalParent;
import org.apache.tinkerpop.gremlin.process.traversal.util.TraversalUtil;
import java.io.Serializable;
+import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import java.util.function.Supplier;
import java.util.stream.Collectors;
/**
@@ -42,23 +44,35 @@ public final class Parameters implements Cloneable, Serializable {
private Map<Object, Object> parameters = new HashMap<>();
- public <S, E> E get(final Traverser.Admin<S> traverser, final Object key) {
+ public boolean contains(final Object key) {
+ return this.parameters.containsKey(key);
+ }
+
+ public void replace(final Object oldKey, final Object newKey) {
+ this.set(newKey, this.parameters.remove(oldKey));
+ }
+
+ public <S, E> E get(final Traverser.Admin<S> traverser, final Object key, final Supplier<E> defaultValue) {
final Object object = parameters.get(key);
- return object instanceof Traversal.Admin ? TraversalUtil.apply(traverser, (Traversal.Admin<S, E>) object) : (E) object;
+ return null == object ? defaultValue.get() : object instanceof Traversal.Admin ? TraversalUtil.apply(traverser, (Traversal.Admin<S, E>) object) : (E) object;
+ }
+
+ public <S, E> E get(final Object key, final Supplier<E> defaultValue) {
+ final Object object = parameters.get(key);
+ return null == object ? defaultValue.get() : (E) object;
}
public <S> Object[] getKeyValues(final Traverser.Admin<S> traverser, final Object... exceptKeys) {
if (this.parameters.size() == 0) return EMPTY_ARRAY;
final List<Object> exceptions = Arrays.asList(exceptKeys);
- final Object[] keyValues = new Object[(this.parameters.size() * 2) - (exceptKeys.length * 2)];
- int counter = 0;
+ final List<Object> keyValues = new ArrayList<>();
for (final Map.Entry<Object, Object> keyValue : this.parameters.entrySet()) {
if (!exceptions.contains(keyValue.getKey())) {
- keyValues[counter++] = keyValue.getKey() instanceof Traversal.Admin ? TraversalUtil.apply(traverser, (Traversal.Admin<S, ?>) keyValue.getKey()) : keyValue.getKey();
- keyValues[counter++] = keyValue.getValue() instanceof Traversal.Admin ? TraversalUtil.apply(traverser, (Traversal.Admin<S, ?>) keyValue.getValue()) : keyValue.getValue();
+ keyValues.add(keyValue.getKey() instanceof Traversal.Admin ? TraversalUtil.apply(traverser, (Traversal.Admin<S, ?>) keyValue.getKey()) : keyValue.getKey());
+ keyValues.add(keyValue.getValue() instanceof Traversal.Admin ? TraversalUtil.apply(traverser, (Traversal.Admin<S, ?>) keyValue.getValue()) : keyValue.getValue());
}
}
- return keyValues;
+ return keyValues.toArray(new Object[keyValues.size()]);
}
public void set(final Object key, final Object value) {
@@ -93,4 +107,8 @@ public final class Parameters implements Cloneable, Serializable {
public int hashCode() {
return this.parameters.hashCode();
}
+
+ public String toString() {
+ return this.parameters.toString();
+ }
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategy.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategy.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategy.java
index 6927f56..3d04ebe 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategy.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategy.java
@@ -19,6 +19,7 @@
package org.apache.tinkerpop.gremlin.process.traversal.strategy.decoration;
import org.apache.tinkerpop.gremlin.process.traversal.P;
+import org.apache.tinkerpop.gremlin.process.traversal.Parameterizing;
import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
import org.apache.tinkerpop.gremlin.process.traversal.TraversalStrategy;
import org.apache.tinkerpop.gremlin.process.traversal.step.HasContainerHolder;
@@ -35,7 +36,6 @@ import org.apache.tinkerpop.gremlin.process.traversal.util.TraversalHelper;
import org.apache.tinkerpop.gremlin.structure.Element;
import org.apache.tinkerpop.gremlin.structure.PropertyType;
import org.apache.tinkerpop.gremlin.structure.T;
-import org.apache.tinkerpop.gremlin.structure.util.ElementHelper;
import org.apache.tinkerpop.gremlin.structure.util.StringFactory;
import java.util.Arrays;
@@ -83,53 +83,30 @@ public final class ElementIdStrategy extends AbstractTraversalStrategy<Traversal
if (traversal.getStartStep() instanceof GraphStep) {
final GraphStep graphStep = (GraphStep) traversal.getStartStep();
-
// only need to apply the custom id if ids were assigned - otherwise we want the full iterator.
// note that it is then only necessary to replace the step if the id is a non-element. other tests
// in the suite validate that items in getIds() is uniform so it is ok to just test the first item
// in the list.
if (graphStep.getIds().length > 0 && !(graphStep.getIds()[0] instanceof Element)) {
- if (graphStep instanceof HasContainerHolder) {
+ if (graphStep instanceof HasContainerHolder)
((HasContainerHolder) graphStep).addHasContainer(new HasContainer(this.idPropertyKey, P.within(Arrays.asList(graphStep.getIds()))));
- } else {
+ else
TraversalHelper.insertAfterStep(new HasStep(traversal, new HasContainer(this.idPropertyKey, P.within(Arrays.asList(graphStep.getIds())))), graphStep, traversal);
- }
graphStep.clearIds();
}
}
-
- TraversalHelper.getStepsOfAssignableClass(IdStep.class, traversal).stream().forEach(s -> {
- TraversalHelper.replaceStep(s, new PropertiesStep(traversal, PropertyType.VALUE, idPropertyKey), traversal);
+ TraversalHelper.getStepsOfAssignableClass(IdStep.class, traversal).stream().forEach(step -> {
+ TraversalHelper.replaceStep(step, new PropertiesStep(traversal, PropertyType.VALUE, idPropertyKey), traversal);
});
// in each case below, determine if the T.id is present and if so, replace T.id with the idPropertyKey or if
// it is not present then shove it in there and generate an id
- TraversalHelper.getStepsOfAssignableClass(AddVertexStep.class, traversal).stream().forEach(s -> {
- if (ElementHelper.getIdValue(s.getKeyValues()).isPresent()) {
-
- //TraversalHelper.replaceStep(s, new AddVertexStep(traversal, ElementHelper.replaceKey(s.getKeyValues(), T.id, idPropertyKey)), traversal);
- } else {
- final Object[] kvs = ElementHelper.getKeys(s.getKeyValues()).contains(idPropertyKey) ? s.getKeyValues() : ElementHelper.upsert(s.getKeyValues(), idPropertyKey, idMaker.get());
- // TraversalHelper.replaceStep(s, new AddVertexStep(traversal, kvs), traversal);
- }
- });
-
- TraversalHelper.getStepsOfAssignableClass(AddVertexStartStep.class, traversal).stream().forEach(s -> {
- if (ElementHelper.getIdValue(s.getKeyValues()).isPresent()) {
- // TraversalHelper.replaceStep(s, new AddVertexStartStep(traversal, ElementHelper.replaceKey(s.getKeyValues(), T.id, idPropertyKey)), traversal);
- } else {
- final Object[] kvs = ElementHelper.getKeys(s.getKeyValues()).contains(idPropertyKey) ? s.getKeyValues() : ElementHelper.upsert(s.getKeyValues(), idPropertyKey, idMaker.get());
- // TraversalHelper.replaceStep(s, new AddVertexStartStep(traversal, kvs), traversal);
- }
-
- });
-
- TraversalHelper.getStepsOfAssignableClass(AddEdgeStep.class, traversal).stream().forEach(s -> {
- if (ElementHelper.getIdValue(s.getPropertyKeyValues()).isPresent())
- TraversalHelper.replaceStep(s, new AddEdgeStep(traversal, s.getDirection(), s.getFirstVertexKey(), s.getEdgeLabel(), s.getSecondVertexKey(), ElementHelper.replaceKey(s.getPropertyKeyValues(), T.id, idPropertyKey)), traversal);
- else {
- final Object[] kvs = ElementHelper.getKeys(s.getPropertyKeyValues()).contains(idPropertyKey) ? s.getPropertyKeyValues() : ElementHelper.upsert(s.getPropertyKeyValues(), idPropertyKey, idMaker.get());
- TraversalHelper.replaceStep(s, new AddEdgeStep(traversal, s.getDirection(), s.getFirstVertexKey(), s.getEdgeLabel(), s.getSecondVertexKey(), kvs), traversal);
+ traversal.getSteps().forEach(step -> {
+ if (step instanceof AddVertexStep || step instanceof AddVertexStartStep || step instanceof AddEdgeStep) {
+ if (((Parameterizing) step).getParameters().contains(T.id))
+ ((Parameterizing) step).getParameters().replace(T.id, this.idPropertyKey);
+ else if (!((Parameterizing) step).getParameters().contains(this.idPropertyKey))
+ ((Parameterizing) step).getParameters().set(this.idPropertyKey, idMaker.get());
}
});
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategy.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategy.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategy.java
index aa0b648..943380c 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategy.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategy.java
@@ -22,6 +22,7 @@ import org.apache.tinkerpop.gremlin.process.traversal.P;
import org.apache.tinkerpop.gremlin.process.traversal.Step;
import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
import org.apache.tinkerpop.gremlin.process.traversal.TraversalStrategy;
+import org.apache.tinkerpop.gremlin.process.traversal.step.Mutating;
import org.apache.tinkerpop.gremlin.process.traversal.step.filter.HasStep;
import org.apache.tinkerpop.gremlin.process.traversal.step.map.AddEdgeStep;
import org.apache.tinkerpop.gremlin.process.traversal.step.map.AddVertexStartStep;
@@ -39,10 +40,10 @@ import java.util.Collections;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
-import java.util.stream.Stream;
/**
* @author Stephen Mallette (http://stephen.genoprime.com)
+ * @author Marko A. Rodriguez (http://markorodriguez.com)
*/
public final class PartitionStrategy extends AbstractTraversalStrategy<TraversalStrategy.DecorationStrategy> implements TraversalStrategy.DecorationStrategy {
private String writePartition;
@@ -83,29 +84,14 @@ public final class PartitionStrategy extends AbstractTraversalStrategy<Traversal
stepsToInsertHasAfter.addAll(TraversalHelper.getStepsOfAssignableClass(EdgeVertexStep.class, traversal));
// all steps that return a vertex need to have has(paritionKey,within,partitionValues) injected after it
- stepsToInsertHasAfter.forEach(s -> TraversalHelper.insertAfterStep(
- new HasStep(traversal, new HasContainer(partitionKey, P.within(new ArrayList<>(readPartitions)))), s, traversal));
+ stepsToInsertHasAfter.forEach(step -> TraversalHelper.insertAfterStep(
+ new HasStep(traversal, new HasContainer(this.partitionKey, P.within(new ArrayList<>(this.readPartitions)))), step, traversal));
- // all write edge steps need to have partition keys tossed into the property key/value list after mutating steps
- TraversalHelper.getStepsOfAssignableClass(AddEdgeStep.class, traversal).forEach(s -> {
- final Object[] keyValues = injectPartitionInfo(s.getPropertyKeyValues());
- TraversalHelper.replaceStep(s, new AddEdgeStep(traversal, s.getDirection(), s.getFirstVertexKey(), s.getEdgeLabel(), s.getSecondVertexKey(), keyValues), traversal);
+ traversal.getSteps().forEach(step -> {
+ if (step instanceof AddEdgeStep || step instanceof AddVertexStep || step instanceof AddVertexStartStep) {
+ ((Mutating) step).addPropertyMutations(this.partitionKey, this.writePartition);
+ }
});
-
- // all write vertex steps need to have partition keys tossed into the property key/value list after mutating steps
- TraversalHelper.getStepsOfAssignableClass(AddVertexStep.class, traversal).forEach(s -> {
- final Object[] keyValues = injectPartitionInfo(s.getKeyValues());
- //TraversalHelper.replaceStep(s, new AddVertexStep(traversal, keyValues), traversal);
- });
-
- TraversalHelper.getStepsOfAssignableClass(AddVertexStartStep.class, traversal).forEach(s -> {
- final Object[] keyValues = injectPartitionInfo(s.getKeyValues());
- //TraversalHelper.replaceStep(s, new AddVertexStartStep(traversal, keyValues), traversal);
- });
- }
-
- private Object[] injectPartitionInfo(final Object[] propertyKeyValues) {
- return Stream.concat(Stream.of(propertyKeyValues), Stream.of(partitionKey, writePartition)).toArray();
}
public final static class Builder {
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalTest.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalTest.java b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalTest.java
index 6f16da6..174a97e 100644
--- a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalTest.java
+++ b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalTest.java
@@ -34,7 +34,7 @@ import java.util.Set;
*/
public class GraphTraversalTest {
- private static Set<String> NO_GRAPH = new HashSet<>(Arrays.asList("asAdmin", "by", "option", "iterate"));
+ private static Set<String> NO_GRAPH = new HashSet<>(Arrays.asList("asAdmin", "by", "option", "iterate", "to", "from", "id"));
private static Set<String> NO_ANONYMOUS = new HashSet<>(Arrays.asList("start", "__"));
@Test
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStepTest.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStepTest.java b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStepTest.java
index 204f5cd..e418781 100644
--- a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStepTest.java
+++ b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStepTest.java
@@ -24,7 +24,6 @@ package org.apache.tinkerpop.gremlin.process.traversal.step.map;
import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.__;
import org.apache.tinkerpop.gremlin.process.traversal.step.StepTest;
-import org.apache.tinkerpop.gremlin.structure.Direction;
import java.util.Arrays;
import java.util.List;
@@ -37,11 +36,10 @@ public class AddEdgeStepTest extends StepTest {
@Override
protected List<Traversal> getTraversals() {
return Arrays.asList(
- __.addE(Direction.IN, "knows", "x"),
- __.addE(Direction.IN, "knows", "y"),
- __.addE(Direction.OUT, "knows", "x"),
- __.addE(Direction.IN, "knows", "x", "weight", 0),
- __.addE(Direction.IN, "knows", "x", "weight", 1)
+ __.addE("knows").property("a", "b"),
+ __.addE("created").property("a", "b"),
+ __.addE("knows").property("a", "b").property("c", "d"),
+ __.addE("knows").property("c", "d")
);
}
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyTraverseTest.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyTraverseTest.java b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyTraverseTest.java
index f3ad539..f05d938 100644
--- a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyTraverseTest.java
+++ b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/ElementIdStrategyTraverseTest.java
@@ -27,10 +27,8 @@ import org.apache.tinkerpop.gremlin.process.traversal.step.map.AddVertexStartSte
import org.apache.tinkerpop.gremlin.process.traversal.step.map.AddVertexStep;
import org.apache.tinkerpop.gremlin.process.traversal.step.map.PropertiesStep;
import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.GraphStep;
-import org.apache.tinkerpop.gremlin.structure.Direction;
import org.apache.tinkerpop.gremlin.structure.Graph;
import org.apache.tinkerpop.gremlin.structure.Vertex;
-import org.apache.tinkerpop.gremlin.structure.util.ElementHelper;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.junit.runners.Parameterized;
@@ -42,6 +40,7 @@ import static org.mockito.Mockito.mock;
/**
* @author Stephen Mallette (http://stephen.genoprime.com)
+ * @author Marko A. Rodriguez (http://markorodriguez.com)
*/
@RunWith(Parameterized.class)
public class ElementIdStrategyTraverseTest {
@@ -58,22 +57,19 @@ public class ElementIdStrategyTraverseTest {
public static Iterable<Object[]> data() {
return Arrays.asList(new Object[][]{
{"addV()", traversalWithAddV, 1},
- {"addInE()", __.addInE("test", "x"), 0},
- {"addOutE()", __.addOutE("test", "x"), 0},
- {"addInE()", __.addInE("test", "x", "other", "args"), 0},
- {"addOutE()", __.addOutE("test", "x", "other", "args"), 0},
- {"addE(OUT)", __.addE(Direction.OUT, "test", "x"), 0},
- {"addE(IN)", __.addE(Direction.IN, "test", "x"), 0},
+ {"addE(test).from(x)", __.addE("test").from("x"), 0},
+ {"addE(test).to(x)", __.addE("test").to("x"), 0},
+ {"addE(test).from(x).property(key,value)", __.addE("test").from("x").property("key", "value"), 0},
+ {"addE(test).to(x).property(key,value)", __.addE("test").to("x").property("key", "value"), 0},
{"out().id()", __.out().id(), 1},
{"in().id()", __.in().id(), 1},
{"outE().id()", __.outE().id(), 1},
{"inE().id()", __.inE().id(), 1},
{"bothE().id()", __.bothE().id(), 1},
{"bothE().otherV().id()", __.bothE().otherV().id(), 2},
- {"in().out().addInE()", __.in().out().addInE("test", "x"), 2},
- {"in().out().addOutE()", __.in().out().addOutE("test", "x"), 2},
- {"in().out().addE(OUT)", __.in().out().addE(Direction.OUT, "test", "x"), 2},
- {"in().out().addE(IN)", __.in().out().addE(Direction.IN, "test", "x"), 2}});
+ {"in().out().addE(test).from(x)", __.in().out().addE("test").from("x"), 2},
+ {"in().out().addE(test).to(x)", __.in().out().addE("test").to("x"), 2},
+ });
}
@Parameterized.Parameter(value = 0)
@@ -90,15 +86,15 @@ public class ElementIdStrategyTraverseTest {
final ElementIdStrategy strategy = ElementIdStrategy.build().create();
strategy.apply(traversal.asAdmin());
- final Step s = (Step) traversal.asAdmin().getSteps().get(expectedInsertedSteps);
- if (s instanceof AddVertexStep)
- assertTrue(ElementHelper.getKeys(((AddVertexStep) s).getKeyValues()).contains(strategy.getIdPropertyKey()));
- else if (s instanceof AddVertexStartStep)
- assertTrue(ElementHelper.getKeys(((AddVertexStartStep) s).getKeyValues()).contains(strategy.getIdPropertyKey()));
- else if (s instanceof AddEdgeStep)
- assertTrue(ElementHelper.getKeys(((AddEdgeStep) s).getPropertyKeyValues()).contains(strategy.getIdPropertyKey()));
- else if (s instanceof PropertiesStep)
- assertEquals(strategy.getIdPropertyKey(), ((PropertiesStep) s).getPropertyKeys()[0]);
+ final Step step = (Step) traversal.asAdmin().getSteps().get(expectedInsertedSteps);
+ if (step instanceof AddVertexStep)
+ assertTrue(((AddVertexStep) step).getParameters().contains(strategy.getIdPropertyKey()));
+ else if (step instanceof AddVertexStartStep)
+ assertTrue(((AddVertexStartStep) step).getParameters().contains(strategy.getIdPropertyKey()));
+ else if (step instanceof AddEdgeStep)
+ assertTrue(((AddEdgeStep) step).getParameters().contains(strategy.getIdPropertyKey()));
+ else if (step instanceof PropertiesStep)
+ assertEquals(strategy.getIdPropertyKey(), ((PropertiesStep) step).getPropertyKeys()[0]);
else
fail("Check test definition - the expectedInsertedSteps should be the index of the step to trigger the ID substitution");
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyTest.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyTest.java b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyTest.java
index fedc874..8dc4d24 100644
--- a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyTest.java
+++ b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategyTest.java
@@ -36,23 +36,20 @@ import static org.junit.Assert.assertEquals;
/**
* @author Stephen Mallette (http://stephen.genoprime.com)
+ * @author Marko A. Rodriguez (http://markorodriguez.com)
*/
@RunWith(Parameterized.class)
public class EventStrategyTest {
@Parameterized.Parameters(name = "{0}")
public static Iterable<Object[]> data() {
return Arrays.asList(new Object[][]{
- {"addInE()", new DefaultGraphTraversal<>(EmptyGraph.instance()).addInE("test", "x"), 1},
- {"addInE(args)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addInE("test", "x", "this", "that"), 1},
- {"addOutE()", new DefaultGraphTraversal<>(EmptyGraph.instance()).addOutE("test", "x"), 1},
- {"addOutE(args)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addOutE("test", "x", "this", "that"), 1},
- {"addE(IN)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE(Direction.IN, "test", "test"), 1},
- {"addE(IN,args)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE(Direction.IN, "test", "test", "this", "that"), 1},
- {"addE(OUT)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE(Direction.OUT, "test", "test"), 1},
- {"addE(OUT,args)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE(Direction.OUT, "test", "test", "this", "that"), 1},
+ {"addE(test).from(x)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE("test").from("x"), 1},
+ {"addE(test).from(x).property(this,that)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE("test").from("x").property("this", "that"), 1},
+ {"addE(test).to(x)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE("test").to("x"), 1},
+ {"addE(test).to(x).property(this,that)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE("test").to("x").property("this", "that"), 1},
{"addV()", new DefaultGraphTraversal<>(EmptyGraph.instance()).addV(), 1},
- // {"addV(args)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addV("test", "this"), 1},
- {"addV().property(k,v)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addV().property("test", "that"), 2},
+ {"addV(args)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addV("test", "this"), 1},
+ {"addV().property(k,v)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addV().property("test", "that"), 1},
{"properties().drop()", new DefaultGraphTraversal<>(EmptyGraph.instance()).properties().drop(), 1},
{"properties(k).drop()", new DefaultGraphTraversal<>(EmptyGraph.instance()).properties("test").drop(), 1},
{"out().drop()", new DefaultGraphTraversal<>(EmptyGraph.instance()).out().drop(), 1},
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyTraverseTest.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyTraverseTest.java b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyTraverseTest.java
index d0c17e0..29d6dc0 100644
--- a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyTraverseTest.java
+++ b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/PartitionStrategyTraverseTest.java
@@ -29,11 +29,10 @@ import org.apache.tinkerpop.gremlin.process.traversal.step.map.AddVertexStep;
import org.apache.tinkerpop.gremlin.process.traversal.step.sideEffect.GraphStep;
import org.apache.tinkerpop.gremlin.process.traversal.step.util.HasContainer;
import org.apache.tinkerpop.gremlin.process.traversal.util.TraversalHelper;
-import org.apache.tinkerpop.gremlin.structure.Direction;
+import org.apache.tinkerpop.gremlin.structure.Edge;
import org.apache.tinkerpop.gremlin.structure.Graph;
+import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
-import org.apache.tinkerpop.gremlin.structure.util.ElementHelper;
-import org.javatuples.Pair;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.junit.runners.Parameterized;
@@ -42,7 +41,8 @@ import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
-import static org.junit.Assert.*;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.fail;
import static org.mockito.Mockito.mock;
/**
@@ -73,17 +73,13 @@ public class PartitionStrategyTraverseTest {
{"out(args)", __.out("test"), 1, false},
{"out().inE().otherV", __.out().inE().otherV(), 3, false},
{"addV()", traversalWithAddV, 1, true},
- {"addInE()", __.addInE("test", "x"), 0, true},
- {"addOutE()", __.addOutE("test", "x"), 0, true},
- {"addInE()", __.addInE("test", "x", "other", "args"), 0, true},
- {"addOutE()", __.addOutE("test", "x", "other", "args"), 0, true},
- {"addE(OUT)", __.addE(Direction.OUT, "test", "x"), 0, true},
- {"addE(IN)", __.addE(Direction.IN, "test", "x"), 0, true},
+ {"addE(test).from(x)", __.addE("test").from("x"), 0, true},
+ {"addE(test).to(x)", __.addE("test").to("x"), 0, true},
+ {"addE(test).from(x).property(other,args)", __.addE("test").from("x").property("other", "args"), 0, true},
+ {"addE(test).to(x).property(other,args)", __.addE("test").to("x").property("other", "args"), 0, true},
{"in().out()", __.in().out(), 2, false},
- {"in().out().addInE()", __.in().out().addInE("test", "x"), 2, true},
- {"in().out().addOutE()", __.in().out().addOutE("test", "x"), 2, true},
- {"in().out().addE(OUT)", __.in().out().addE(Direction.OUT, "test", "x"), 2, true},
- {"in().out().addE(IN)", __.in().out().addE(Direction.IN, "test", "x"), 2, true},
+ {"in().out().addE(test).from(x)", __.in().out().addE("test").from("x"), 2, true},
+ {"in().out().addE(test).to(x)", __.in().out().addE("test").to("x"), 2, true},
{"out().out().out()", __.out().out().out(), 3, false},
{"in().out().in()", __.in().out().in(), 3, false},
{"inE().outV().inE().outV()", __.inE().outV().inE().outV(), 4, false}});
@@ -108,55 +104,23 @@ public class PartitionStrategyTraverseTest {
if (hasMutatingStep) {
if (TraversalHelper.hasStepOfAssignableClass(AddEdgeStep.class, traversal.asAdmin())) {
- final Direction d = TraversalHelper.getStepsOfClass(AddEdgeStep.class, traversal.asAdmin()).get(0).getDirection();
strategy.apply(traversal.asAdmin());
-
final List<AddEdgeStep> addEdgeSteps = TraversalHelper.getStepsOfAssignableClass(AddEdgeStep.class, traversal.asAdmin());
assertEquals(1, addEdgeSteps.size());
-
addEdgeSteps.forEach(s -> {
- final Object[] keyValues = s.getPropertyKeyValues();
- final List<Pair<String, Object>> pairs = ElementHelper.asPairs(keyValues);
- assertEquals("test", s.getEdgeLabel());
- assertEquals(d, s.getDirection());
- assertTrue(pairs.stream().anyMatch(p -> p.getValue0().equals("p") && p.getValue1().equals("a")));
- });
- } else if (TraversalHelper.hasStepOfAssignableClass(AddEdgeStep.class, traversal.asAdmin())) {
- final Direction d = TraversalHelper.getStepsOfClass(AddEdgeStep.class, traversal.asAdmin()).get(0).getDirection();
- strategy.apply(traversal.asAdmin());
-
- final List<AddEdgeStep> addEdgeSteps = TraversalHelper.getStepsOfAssignableClass(AddEdgeStep.class, traversal.asAdmin());
- assertEquals(1, addEdgeSteps.size());
-
- addEdgeSteps.forEach(s -> {
- final Object[] keyValues = s.getPropertyKeyValues();
- final List<Pair<String, Object>> pairs = ElementHelper.asPairs(keyValues);
- assertEquals("test", s.getEdgeLabel());
- assertEquals(d, s.getDirection());
- assertTrue(pairs.stream().anyMatch(p -> p.getValue0().equals("p") && p.getValue1().equals("a")));
+ assertEquals("test", s.getParameters().get(T.label, () -> Edge.DEFAULT_LABEL));
+ assertEquals("a", s.getParameters().get("p", null));
});
} else if (TraversalHelper.hasStepOfAssignableClass(AddVertexStep.class, traversal.asAdmin())) {
strategy.apply(traversal.asAdmin());
-
final List<AddVertexStep> addVertexSteps = TraversalHelper.getStepsOfAssignableClass(AddVertexStep.class, traversal.asAdmin());
assertEquals(1, addVertexSteps.size());
-
- addVertexSteps.forEach(s -> {
- final Object[] keyValues = s.getKeyValues();
- final List<Pair<String, Object>> pairs = ElementHelper.asPairs(keyValues);
- assertTrue(pairs.stream().anyMatch(p -> p.getValue0().equals("p") && p.getValue1().equals("a")));
- });
+ addVertexSteps.forEach(s -> assertEquals("a", s.getParameters().get("p", null)));
} else if (TraversalHelper.hasStepOfAssignableClass(AddVertexStartStep.class, traversal.asAdmin())) {
strategy.apply(traversal.asAdmin());
-
final List<AddVertexStartStep> addVertexSteps = TraversalHelper.getStepsOfAssignableClass(AddVertexStartStep.class, traversal.asAdmin());
assertEquals(1, addVertexSteps.size());
-
- addVertexSteps.forEach(s -> {
- final Object[] keyValues = s.getKeyValues();
- final List<Pair<String, Object>> pairs = ElementHelper.asPairs(keyValues);
- assertTrue(pairs.stream().anyMatch(p -> p.getValue0().equals("p") && p.getValue1().equals("a")));
- });
+ addVertexSteps.forEach(s -> assertEquals("a", s.getParameters().get("p", null)));
} else
fail("This test should not be marked as having a mutating step or there is something else amiss.");
} else {
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/SubgraphStrategyTraverseTest.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/SubgraphStrategyTraverseTest.java b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/SubgraphStrategyTraverseTest.java
index 8c668c8..5ca15e6 100644
--- a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/SubgraphStrategyTraverseTest.java
+++ b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/SubgraphStrategyTraverseTest.java
@@ -65,17 +65,17 @@ public class SubgraphStrategyTraverseTest {
{"out(args)", __.out("test"), 2},
{"out().inE().otherV", __.out().inE().otherV(), 4},
{"addV()", traversalWithAddV, 2},
- {"addInE()", __.addInE("test", "x"), 1},
- {"addOutE()", __.addOutE("test", "x"), 1},
- {"addInE()", __.addInE("test", "x", "other", "args"), 1},
- {"addOutE()", __.addOutE("test", "x", "other", "args"), 1},
- {"addE(OUT)", __.addE(Direction.OUT, "test", "x"), 1},
- {"addE(IN)", __.addE(Direction.IN, "test", "x"), 1},
+ // {"addInE()", __.addInE("test", "x"), 1},
+ // {"addOutE()", __.addOutE("test", "x"), 1},
+ // {"addInE()", __.addInE("test", "x", "other", "args"), 1},
+ // {"addOutE()", __.addOutE("test", "x", "other", "args"), 1},
+ // {"addE(OUT)", __.addE(Direction.OUT, "test", "x"), 1},
+ // {"addE(IN)", __.addE(Direction.IN, "test", "x"), 1},
{"in().out()", __.in().out(), 4},
- {"in().out().addInE()", __.in().out().addInE("test", "x"), 5},
- {"in().out().addOutE()", __.in().out().addOutE("test", "x"), 5},
- {"in().out().addE(OUT)", __.in().out().addE(Direction.OUT, "test", "x"), 5},
- {"in().out().addE(IN)", __.in().out().addE(Direction.IN, "test", "x"), 5},
+ // {"in().out().addInE()", __.in().out().addInE("test", "x"), 5},
+ // {"in().out().addOutE()", __.in().out().addOutE("test", "x"), 5},
+ // {"in().out().addE(OUT)", __.in().out().addE(Direction.OUT, "test", "x"), 5},
+ // {"in().out().addE(IN)", __.in().out().addE(Direction.IN, "test", "x"), 5},
{"out().out().out()", __.out().out().out(), 6},
{"in().out().in()", __.in().out().in(), 6},
{"inE().outV().inE().outV()", __.inE().outV().inE().outV(), 4}});
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyTest.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyTest.java b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyTest.java
index 843ecfa..8452b53 100644
--- a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyTest.java
+++ b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/verification/ReadOnlyStrategyTest.java
@@ -20,9 +20,6 @@ package org.apache.tinkerpop.gremlin.process.traversal.strategy.verification;
import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.DefaultGraphTraversal;
-import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.__;
-import org.apache.tinkerpop.gremlin.process.traversal.strategy.verification.ReadOnlyStrategy;
-import org.apache.tinkerpop.gremlin.structure.Direction;
import org.apache.tinkerpop.gremlin.structure.VertexProperty;
import org.apache.tinkerpop.gremlin.structure.util.empty.EmptyGraph;
import org.junit.Test;
@@ -42,14 +39,10 @@ public class ReadOnlyStrategyTest {
@Parameterized.Parameters(name = "{0}")
public static Iterable<Object[]> data() {
return Arrays.asList(new Object[][]{
- {"addInE()", new DefaultGraphTraversal<>(EmptyGraph.instance()).addInE("test", "x")},
- {"addInE(args)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addInE("test", "x", "this", "that")},
- {"addOutE()", new DefaultGraphTraversal<>(EmptyGraph.instance()).addOutE("test", "x")},
- {"addOutE(args)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addOutE("test", "x", "this", "that")},
- {"addE(IN)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE(Direction.IN, "test", "test")},
- {"addE(IN,args)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE(Direction.IN, "test", "test", "this", "that")},
- {"addE(OUT)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE(Direction.OUT, "test", "test")},
- {"addE(OUT,args)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE(Direction.OUT, "test", "test", "this", "that")},
+ {"addE(test).from(x)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE("test").from("x")},
+ {"addE(test).from(x).property(this,that)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE("test").from("x").property("this", "that")},
+ {"addE(test).to(x)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE("test").to("x")},
+ {"addE(test).to(x).property(this,that)", new DefaultGraphTraversal<>(EmptyGraph.instance()).addE("test").to("x").property("this", "that")},
{"outE().property(k,v)", new DefaultGraphTraversal<>(EmptyGraph.instance()).outE().property("test", "test")},
{"out().properties(k).property(k,v)", new DefaultGraphTraversal<>(EmptyGraph.instance()).out().properties("test").property("test", "that")},
{"out().property(k,v)", new DefaultGraphTraversal<>(EmptyGraph.instance()).out().property("test", "test")},
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddEdgeTest.groovy
----------------------------------------------------------------------
diff --git a/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddEdgeTest.groovy b/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddEdgeTest.groovy
index f9109d2..91b61fb 100644
--- a/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddEdgeTest.groovy
+++ b/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddEdgeTest.groovy
@@ -31,6 +31,32 @@ public abstract class GroovyAddEdgeTest {
public static class Traversals extends AddEdgeTest {
@Override
+ public Traversal<Vertex, Edge> get_g_VX1X_asXaX_outXcreatedX_addEXcreatedByX_toXaX(final Object v1Id) {
+ TraversalScriptHelper.compute("g.V(${v1Id}).as('a').out('created').addE('createdBy').to('a')", g, "v1Id", v1Id)
+ }
+
+ @Override
+ public Traversal<Vertex, Edge> get_g_VX1X_asXaX_outXcreatedX_addEXcreatedByX_toXaX_propertyXweight_2X(
+ final Object v1Id) {
+ TraversalScriptHelper.compute("g.V(${v1Id}).as('a').out('created').addE('createdBy').to('a').property('weight', 2)", g, "v1Id", v1Id)
+ }
+
+ /*@Override
+ public Traversal<Vertex, Edge> get_g_withSideEffectXx__g_V_toListX_addOutEXexistsWith_x_time_nowX() {
+ return g.withSideEffect("x", g.V().toList()).V().addE("existsWith").to(__.select("x")).property("time", "now");
+ }*/
+
+ @Override
+ public Traversal<Vertex, Edge> get_g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_addEXcodeveloperX_fromXaX_toXbX_propertyXyear_2009X() {
+ TraversalScriptHelper.compute("g.V.as('a').out('created').in('created').where(neq('a')).as('b').addE('co-developer').from('a').to('b').property('year', 2009)", g)
+ }
+
+ @Override
+ public Traversal<Vertex, Edge> get_g_V_asXaX_inXcreatedX_addEXcreatedByX_fromXaX_propertyXyear_2009X_propertyXacl_publicX() {
+ TraversalScriptHelper.compute("g.V.as('a').in('created').addE('createdBy').from('a').property('year', 2009).property('acl', 'public')", g);
+ }
+
+ @Override
public Traversal<Vertex, Edge> get_g_VX1X_asXaX_outXcreatedX_addOutEXcreatedBy_aX(final Object v1Id) {
TraversalScriptHelper.compute("g.V(v1Id).as('a').out('created').addOutE('createdBy', 'a')", g, "v1Id", v1Id)
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/f314fe67/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy
----------------------------------------------------------------------
diff --git a/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy b/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy
index 390ecdb..cffaaff 100644
--- a/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy
+++ b/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy
@@ -31,22 +31,22 @@ public abstract class GroovyAddVertexTest {
public static class Traversals extends AddVertexTest {
@Override
- public Traversal<Vertex, Vertex> get_g_V_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX(
+ public Traversal<Vertex, Vertex> get_g_VX1X_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX(
final Object v1Id) {
TraversalScriptHelper.compute("g.V(${v1Id}).as('a').addV('animal').property('age', select('a').by('age')).property('name', 'puppy')", g, "v1Id", v1Id);
}
@Override
public Traversal<Vertex, Vertex> get_g_V_addVXanimalX_propertyXage_0X() {
- TraversalScriptHelper.compute("g.V.addV(T.label, 'animal', 'age', 0)", g)
+ TraversalScriptHelper.compute("g.V.addV(label, 'animal', 'age', 0)", g)
}
@Override
public Traversal<Vertex, Vertex> get_g_addVXpersonX_propertyXname_stephenX() {
- TraversalScriptHelper.compute("g.addV(T.label, 'person', 'name', 'stephen')", g)
+ TraversalScriptHelper.compute("g.addV(label, 'person', 'name', 'stephen')", g)
}
- /////////
+ ///////// DEPRECATED BELOW
@Override
public Traversal<Vertex, Vertex> get_g_V_addVXlabel_animal_age_0X() {
@@ -55,7 +55,7 @@ public abstract class GroovyAddVertexTest {
@Override
public Traversal<Vertex, Vertex> get_g_addVXlabel_person_name_stephenX() {
- TraversalScriptHelper.compute("g.V.addV(label, 'person', 'name', 'stephen')", g);
+ TraversalScriptHelper.compute("g.addV(label, 'person', 'name', 'stephen')", g);
}
}
}
[6/8] incubator-tinkerpop git commit: fixed a bug with
meta-properties and property(). Added more test cases. Updated the docs with
the new model. Some cool examples added.
Posted by ok...@apache.org.
fixed a bug with meta-properties and property(). Added more test cases. Updated the docs with the new model. Some cool examples added.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/7beb3698
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/7beb3698
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/7beb3698
Branch: refs/heads/master
Commit: 7beb369811a979e61e967050e632e7f7da8648b5
Parents: 0d0ba7b
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Wed Aug 26 10:49:02 2015 -0600
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Wed Aug 26 10:49:02 2015 -0600
----------------------------------------------------------------------
docs/src/the-traversal.asciidoc | 46 ++++++++++++++------
.../traversal/dsl/graph/GraphTraversal.java | 5 ---
.../process/traversal/step/map/AddEdgeStep.java | 19 ++++----
.../step/sideEffect/AddPropertyStep.java | 30 ++++++-------
.../tinkerpop/gremlin/structure/Graph.java | 2 +-
.../traversal/dsl/graph/GraphTraversalTest.java | 2 +-
.../traversal/step/map/GroovyAddEdgeTest.groovy | 8 ++--
.../step/map/GroovyAddVertexTest.groovy | 5 +++
.../process/traversal/step/map/AddEdgeTest.java | 33 ++++++++++++--
.../traversal/step/map/AddVertexTest.java | 29 ++++++++++++
10 files changed, 127 insertions(+), 52 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/7beb3698/docs/src/the-traversal.asciidoc
----------------------------------------------------------------------
diff --git a/docs/src/the-traversal.asciidoc b/docs/src/the-traversal.asciidoc
index adf65d3..784a852 100644
--- a/docs/src/the-traversal.asciidoc
+++ b/docs/src/the-traversal.asciidoc
@@ -123,16 +123,27 @@ image::addedge-step.png[width=450]
[gremlin-groovy,modern]
----
-g.V(1).as('a').out('created').in('created').where(neq('a')).addOutE('co-developer','a','year',2009) <1>
-g.withSideEffect('a',g.V(3,5).toList()).V(4).addInE('createdBy','a') <2>
-g.V().as('a').out('created').as('b').select('a','b').addOutE('b','createdBy','a','acl','public') <3>
-g.V(1).as('a').out('knows').addInE('livesNear','a','year',2009).inV().inE('livesNear').values('year') <4>
+g.V(1).as('a').out('created').in('created').where(neq('a')).
+ addE('co-developer').from('a').property('year',2009) <1>
+g.V(3,4,5).aggregate('x').has('name','josh').as('a').select('x').unfold().hasLabel('software').addE('createdBy').to('a') <2>
+g.V().as('a').out('created').addE('createdBy').to('a').property('acl','public') <3>
+g.V(1).as('a').out('knows').
+ addE('livesNear').from('a').property('year',2009).
+ inV().inE('livesNear').values('year') <4>
+g.V().match(
+ __.as('a').out('knows').as('b'),
+ __.as('a').out('created').as('c'),
+ __.as('b').out('created').as('c')).
+ addE('friendlyCollaborator').from('a').to('b').
+ property(id,13).property('project',select('c').values('name')) <5>
+g.E(13).valueMap()
----
<1> Add a co-developer edge with a year-property between marko and his collaborators.
<2> Add incoming createdBy edges from the josh-vertex to the lop- and ripple-vertices.
-<3> It is possible to pull the vertices from a select-projection.
+<3> Add an inverse createdBy edge for all created edges.
<4> The newly created edge is a traversable object.
+<5> Two arbitrary bindings in a traversal can be joined `from()`->`to()`, where `id` can be provided for graphs that supports user provided ids.
[[addvertex-step]]
AddVertex Step
@@ -142,9 +153,9 @@ The `addV()`-step is used to add vertices to the graph (*map*/*sideEffect*). For
[gremlin-groovy,modern]
----
-g.addV(label,'person','name','stephen')
+g.addV('person').property('name','stephen')
g.V().values('name')
-g.V().outE('knows').addV('name','nothing')
+g.V().outE('knows').addV().property('name','nothing')
g.V().has('name','nothing')
g.V().has('name','nothing').bothE()
----
@@ -153,16 +164,23 @@ g.V().has('name','nothing').bothE()
AddProperty Step
~~~~~~~~~~~~~~~~
-The `property()`-step is used to add properties to the elements of the graph (*sideEffect*). Unlike `addV()` and `addE()`, `property()` is a full sideEffect step in that it does not return the property it created, but the element that streamed into it.
+The `property()`-step is used to add properties to the elements of the graph (*sideEffect*). Unlike `addV()` and `addE()`, `property()` is a full sideEffect step in that it does not return the property it created, but the element that streamed into it. Moreover, if `property()` follows an `addV()` or `addE()`, then it is "folded" into the previous step to enable vertex and edge creation with all its properties in one creation operation.
[gremlin-groovy,modern]
----
g.V(1).property('country','usa')
g.V(1).property('city','santa fe').property('state','new mexico').valueMap()
-g.V(1).property(list,'age',35)
+g.V(1).property(list,'age',35) <1>
g.V(1).valueMap()
+g.V(1).property('friendWeight',outE('knows').values('weight').sum(),'acl','private') <2>
+g.V(1).properties('friendWeight').valueMap() <3>
----
+<1> For vertices, a cardinality can be provided for <<vertex properties,vertex-properties>>.
+<2> It is possible to select the property value (as well as key) via a traversal.
+<3> For vertices, the `property()`-step can add meta-properties.
+
+
[[aggregate-step]]
Aggregate Step
~~~~~~~~~~~~~~
@@ -804,7 +822,7 @@ g.V().match(
__.as('a').out('created').has('name','lop').as('b'), <1>
__.as('b').in('created').has('age', 29).as('c'),
__.as('c').repeat(out()).times(2)). <2>
- select('c').out('knows').dedup().values('name') <3>
+ select('c').out('knows').dedup().values('name') <3>
----
<1> *Patterns of arbitrary complexity*: `match()` is not restricted to triple patterns or property paths.
@@ -819,10 +837,10 @@ g.V().match(
__.as('a').out('knows').as('b'),
__.as('b').out('created').has('name','lop')).
select('b').out('created').
- match(
- __.as('x').in('created').as('y'),
- __.as('y').out('knows').as('z')).
- select('z').values('name')
+ match(
+ __.as('x').in('created').as('y'),
+ __.as('y').out('knows').as('z')).
+ select('z').values('name')
----
IMPORTANT: The `match()`-step is stateless. The variable bindings of the traversal patterns are stored in the path history of the traverser. As such, the variables used over all `match()`-steps within a traversal are globally unique. A benefit of this is that subsequent `where()`, `select()`, `match()`, etc. steps can leverage the same variables in their analysis.
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/7beb3698/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
index 2fad998..f4a0374 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversal.java
@@ -677,11 +677,6 @@ public interface GraphTraversal<S, E> extends Traversal<S, E> {
return this;
}
- public default GraphTraversal<S, E> id(final Object elementId) {
- ((Mutating) this.asAdmin().getEndStep()).addPropertyMutations(T.id, elementId);
- return this;
- }
-
/**
* @deprecated As of release 3.1.0, replaced by {@link #addE(String)}
*/
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/7beb3698/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java
index 6a83a59..91f3c05 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeStep.java
@@ -34,7 +34,9 @@ import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.apache.tinkerpop.gremlin.structure.util.StringFactory;
import org.apache.tinkerpop.gremlin.structure.util.detached.DetachedFactory;
+import org.apache.tinkerpop.gremlin.util.iterator.IteratorUtils;
+import java.util.Iterator;
import java.util.List;
import java.util.Set;
@@ -83,14 +85,15 @@ public final class AddEdgeStep<S> extends MapStep<S, Edge> implements Mutating<E
@Override
protected Edge map(final Traverser.Admin<S> traverser) {
- final Edge edge =
- this.parameters.get(traverser, FROM, () -> (Vertex) traverser.get()).
- addEdge(this.parameters.get(traverser, T.label, () -> Edge.DEFAULT_LABEL),
- this.parameters.get(traverser, TO, () -> (Vertex) traverser.get()), this.parameters.getKeyValues(traverser, TO, FROM, T.label));
- if (callbackRegistry != null) {
- final Event.EdgeAddedEvent vae = new Event.EdgeAddedEvent(DetachedFactory.detach(edge, true));
- callbackRegistry.getCallbacks().forEach(c -> c.accept(vae));
- }
+ final Vertex toVertex = this.parameters.get(traverser, TO, () -> (Vertex) traverser.get());
+ final Vertex fromVertex = this.parameters.get(traverser, FROM, () -> (Vertex) traverser.get());
+ final String edgeLabel = this.parameters.get(traverser, T.label, () -> Edge.DEFAULT_LABEL);
+
+ final Edge edge = fromVertex.addEdge(edgeLabel, toVertex, this.parameters.getKeyValues(traverser, TO, FROM, T.label));
+ if (callbackRegistry != null) {
+ final Event.EdgeAddedEvent vae = new Event.EdgeAddedEvent(DetachedFactory.detach(edge, true));
+ callbackRegistry.getCallbacks().forEach(c -> c.accept(vae));
+ }
return edge;
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/7beb3698/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
index ccae521..3405ce9 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/AddPropertyStep.java
@@ -83,31 +83,31 @@ public final class AddPropertyStep<S extends Element> extends SideEffectStep<S>
});
final Object[] vertexPropertyKeyValues = this.parameters.getKeyValues(traverser, T.key, T.value);
+ final Element element = traverser.get();
+ final boolean runtimeAsVertex = element instanceof Vertex;
+
if (this.callbackRegistry != null) {
- final Element currentElement = traverser.get();
final Property currentProperty = traverser.get().property(key);
-
- // todo: have to do a runtime check until TINKERPOP3-783 is done - asVertex is not reliable
- final boolean runtimeAsVertex = currentElement instanceof Vertex;
final boolean newProperty = runtimeAsVertex ? currentProperty == VertexProperty.empty() : currentProperty == Property.empty();
-
- Event.ElementPropertyChangedEvent evt;
- if (currentElement instanceof Vertex)
- evt = new Event.VertexPropertyChangedEvent(DetachedFactory.detach((Vertex) currentElement, true), newProperty ? null : DetachedFactory.detach((VertexProperty) currentProperty, true), value, vertexPropertyKeyValues);
- else if (currentElement instanceof Edge)
- evt = new Event.EdgePropertyChangedEvent(DetachedFactory.detach((Edge) currentElement, true), newProperty ? null : DetachedFactory.detach(currentProperty), value);
- else if (currentElement instanceof VertexProperty)
- evt = new Event.VertexPropertyPropertyChangedEvent(DetachedFactory.detach((VertexProperty) currentElement, true), newProperty ? null : DetachedFactory.detach(currentProperty), value);
+ final Event.ElementPropertyChangedEvent evt;
+ if (element instanceof Vertex)
+ evt = new Event.VertexPropertyChangedEvent(DetachedFactory.detach((Vertex) element, true), newProperty ? null : DetachedFactory.detach((VertexProperty) currentProperty, true), value, vertexPropertyKeyValues);
+ else if (element instanceof Edge)
+ evt = new Event.EdgePropertyChangedEvent(DetachedFactory.detach((Edge) element, true), newProperty ? null : DetachedFactory.detach(currentProperty), value);
+ else if (element instanceof VertexProperty)
+ evt = new Event.VertexPropertyPropertyChangedEvent(DetachedFactory.detach((VertexProperty) element, true), newProperty ? null : DetachedFactory.detach(currentProperty), value);
else
- throw new IllegalStateException(String.format("The incoming object cannot be processed by change eventing in %s: %s", AddPropertyStep.class.getName(), currentElement));
+ throw new IllegalStateException(String.format("The incoming object cannot be processed by change eventing in %s: %s", AddPropertyStep.class.getName(), element));
this.callbackRegistry.getCallbacks().forEach(c -> c.accept(evt));
}
if (null != this.cardinality)
- ((Vertex) traverser.get()).property(this.cardinality, key, value, vertexPropertyKeyValues);
+ ((Vertex) element).property(this.cardinality, key, value, vertexPropertyKeyValues);
+ else if(runtimeAsVertex)
+ ((Vertex)element).property(key,value,vertexPropertyKeyValues);
else
- traverser.get().property(key, value);
+ element.property(key, value);
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/7beb3698/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/Graph.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/Graph.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/Graph.java
index 432197d..a9b3dc2 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/Graph.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/Graph.java
@@ -175,7 +175,7 @@ public interface Graph extends AutoCloseable, Host {
* <ul>
* <li>g.vertices(v.id())</li>
* </ul>
- * <p/>
+ * <p/>
* If the graph return {@code true} for {@link Features.VertexFeatures#supportsStringIds()} ()} then it should support
* filters as with:
* <ul>
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/7beb3698/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalTest.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalTest.java b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalTest.java
index 174a97e..e0e224f 100644
--- a/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalTest.java
+++ b/gremlin-core/src/test/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalTest.java
@@ -34,7 +34,7 @@ import java.util.Set;
*/
public class GraphTraversalTest {
- private static Set<String> NO_GRAPH = new HashSet<>(Arrays.asList("asAdmin", "by", "option", "iterate", "to", "from", "id"));
+ private static Set<String> NO_GRAPH = new HashSet<>(Arrays.asList("asAdmin", "by", "option", "iterate", "to", "from"));
private static Set<String> NO_ANONYMOUS = new HashSet<>(Arrays.asList("start", "__"));
@Test
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/7beb3698/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddEdgeTest.groovy
----------------------------------------------------------------------
diff --git a/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddEdgeTest.groovy b/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddEdgeTest.groovy
index 91b61fb..15c5286 100644
--- a/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddEdgeTest.groovy
+++ b/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddEdgeTest.groovy
@@ -41,10 +41,10 @@ public abstract class GroovyAddEdgeTest {
TraversalScriptHelper.compute("g.V(${v1Id}).as('a').out('created').addE('createdBy').to('a').property('weight', 2)", g, "v1Id", v1Id)
}
- /*@Override
- public Traversal<Vertex, Edge> get_g_withSideEffectXx__g_V_toListX_addOutEXexistsWith_x_time_nowX() {
- return g.withSideEffect("x", g.V().toList()).V().addE("existsWith").to(__.select("x")).property("time", "now");
- }*/
+ @Override
+ public Traversal<Vertex, Edge> get_g_V_aggregateXxX_asXaX_selectXxX_unfold_addEXexistsWithX_toXaX_propertyXtime_nowX() {
+ TraversalScriptHelper.compute("g.V.aggregate('x').as('a').select('x').unfold.addE('existsWith').to('a').property('time', 'now')", g)
+ }
@Override
public Traversal<Vertex, Edge> get_g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_addEXcodeveloperX_fromXaX_toXbX_propertyXyear_2009X() {
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/7beb3698/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy
----------------------------------------------------------------------
diff --git a/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy b/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy
index cffaaff..7ec2866 100644
--- a/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy
+++ b/gremlin-groovy-test/src/main/groovy/org/apache/tinkerpop/gremlin/process/traversal/step/map/GroovyAddVertexTest.groovy
@@ -46,6 +46,11 @@ public abstract class GroovyAddVertexTest {
TraversalScriptHelper.compute("g.addV(label, 'person', 'name', 'stephen')", g)
}
+ @Override
+ public Traversal<Vertex, Vertex> get_g_V_hasXname_markoX_propertyXfriendWeight_outEXknowsX_weight_sum__acl_privateX() {
+ TraversalScriptHelper.compute("g.V.has('name', 'marko').property('friendWeight', outE('knows').weight.sum(), 'acl', 'private')", g)
+ }
+
///////// DEPRECATED BELOW
@Override
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/7beb3698/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeTest.java
----------------------------------------------------------------------
diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeTest.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeTest.java
index 15eab91..37e59fd 100644
--- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeTest.java
+++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddEdgeTest.java
@@ -48,6 +48,8 @@ public abstract class AddEdgeTest extends AbstractGremlinProcessTest {
public abstract Traversal<Vertex, Edge> get_g_VX1X_asXaX_outXcreatedX_addEXcreatedByX_toXaX_propertyXweight_2X(final Object v1Id);
+ public abstract Traversal<Vertex, Edge> get_g_V_aggregateXxX_asXaX_selectXxX_unfold_addEXexistsWithX_toXaX_propertyXtime_nowX();
+
public abstract Traversal<Vertex, Edge> get_g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_addEXcodeveloperX_fromXaX_toXbX_propertyXyear_2009X();
public abstract Traversal<Vertex, Edge> get_g_V_asXaX_inXcreatedX_addEXcreatedByX_fromXaX_propertyXyear_2009X_propertyXacl_publicX();
@@ -177,6 +179,29 @@ public abstract class AddEdgeTest extends AbstractGremlinProcessTest {
@Test
@LoadGraphWith(MODERN)
+ @FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
+ public void g_V_aggregateXxX_asXaX_selectXxX_unfold_addEXexistsWithX_toXaX_propertyXtime_nowX() {
+ final Traversal<Vertex, Edge> traversal = get_g_V_aggregateXxX_asXaX_selectXxX_unfold_addEXexistsWithX_toXaX_propertyXtime_nowX();
+ printTraversalForm(traversal);
+ int count = 0;
+ while (traversal.hasNext()) {
+ final Edge edge = traversal.next();
+ assertEquals("existsWith", edge.label());
+ assertEquals("now", edge.value("time"));
+ assertEquals(1, IteratorUtils.count(edge.properties()));
+ count++;
+ }
+ assertEquals(36, count);
+ assertEquals(42, IteratorUtils.count(graph.edges()));
+ for (final Vertex vertex : IteratorUtils.list(graph.vertices())) {
+ assertEquals(6, IteratorUtils.count(vertex.edges(Direction.OUT, "existsWith")));
+ assertEquals(6, IteratorUtils.count(vertex.edges(Direction.IN, "existsWith")));
+ }
+ assertEquals(6, IteratorUtils.count(graph.vertices()));
+ }
+
+ @Test
+ @LoadGraphWith(MODERN)
@Deprecated
@FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
public void g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_selectXa_bX_addInEXa_codeveloper_b_year_2009X() {
@@ -289,10 +314,10 @@ public abstract class AddEdgeTest extends AbstractGremlinProcessTest {
return g.V(v1Id).as("a").out("created").addE("createdBy").to("a").property("weight", 2);
}
- /*@Override
- public Traversal<Vertex, Edge> get_g_withSideEffectXx__g_V_toListX_addOutEXexistsWith_x_time_nowX() {
- return g.withSideEffect("x", g.V().toList()).V().addE("existsWith").to(__.select("x")).property("time", "now");
- }*/
+ @Override
+ public Traversal<Vertex, Edge> get_g_V_aggregateXxX_asXaX_selectXxX_unfold_addEXexistsWithX_toXaX_propertyXtime_nowX() {
+ return g.V().aggregate("x").as("a").select("x").unfold().addE("existsWith").to("a").property("time", "now");
+ }
@Override
public Traversal<Vertex, Edge> get_g_V_asXaX_outXcreatedX_inXcreatedX_whereXneqXaXX_asXbX_addEXcodeveloperX_fromXaX_toXbX_propertyXyear_2009X() {
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/7beb3698/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java
----------------------------------------------------------------------
diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java
index fad1519..4019995 100644
--- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java
+++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/AddVertexTest.java
@@ -47,6 +47,8 @@ public abstract class AddVertexTest extends AbstractGremlinTest {
public abstract Traversal<Vertex, Vertex> get_g_addVXpersonX_propertyXname_stephenX();
+ public abstract Traversal<Vertex, Vertex> get_g_V_hasXname_markoX_propertyXfriendWeight_outEXknowsX_weight_sum__acl_privateX();
+
// 3.0.0 DEPRECATIONS
@Deprecated
public abstract Traversal<Vertex, Vertex> get_g_V_addVXlabel_animal_age_0X();
@@ -57,6 +59,7 @@ public abstract class AddVertexTest extends AbstractGremlinTest {
@Test
@LoadGraphWith(MODERN)
@FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
+ @FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_PROPERTY)
public void g_V_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX() {
final Traversal<Vertex, Vertex> traversal = get_g_VX1X_addVXanimalX_propertyXage_selectXaX_byXageXX_propertyXname_puppyX(convertToVertexId(graph, "marko"));
printTraversalForm(traversal);
@@ -72,6 +75,7 @@ public abstract class AddVertexTest extends AbstractGremlinTest {
@Test
@LoadGraphWith(MODERN)
@FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
+ @FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_PROPERTY)
public void g_V_addVXanimalX_propertyXage_0X() {
final Traversal<Vertex, Vertex> traversal = get_g_V_addVXanimalX_propertyXage_0X();
printTraversalForm(traversal);
@@ -90,6 +94,7 @@ public abstract class AddVertexTest extends AbstractGremlinTest {
@Test
@LoadGraphWith(MODERN)
@FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
+ @FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_PROPERTY)
public void g_addVXpersonX_propertyXname_stephenX() {
final Traversal<Vertex, Vertex> traversal = get_g_addVXpersonX_propertyXname_stephenX();
printTraversalForm(traversal);
@@ -101,11 +106,29 @@ public abstract class AddVertexTest extends AbstractGremlinTest {
assertEquals(7, IteratorUtils.count(graph.vertices()));
}
+ @Test
+ @LoadGraphWith(MODERN)
+ @FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
+ @FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_PROPERTY)
+ public void g_V_hasXname_markoX_addVXmetaPersonX_propertyXname_nameX_propertyXfriendWeight_outEXknowsX_weight_sum__acl_privateX() {
+ final Traversal<Vertex, Vertex> traversal = get_g_V_hasXname_markoX_propertyXfriendWeight_outEXknowsX_weight_sum__acl_privateX();
+ printTraversalForm(traversal);
+ final Vertex marko = traversal.next();
+ assertFalse(traversal.hasNext());
+ assertEquals("person", marko.label());
+ assertEquals("marko", marko.value("name"));
+ assertEquals(1.5, marko.value("friendWeight"), 0.01);
+ assertEquals("private", marko.property("friendWeight").value("acl"));
+ assertEquals(3, IteratorUtils.count(marko.properties()));
+ assertEquals(1, IteratorUtils.count(marko.property("friendWeight").properties()));
+ }
+
/////
@Test
@LoadGraphWith(MODERN)
@FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
+ @FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_PROPERTY)
public void g_V_addVXlabel_animal_age_0X() {
final Traversal<Vertex, Vertex> traversal = get_g_V_addVXlabel_animal_age_0X();
printTraversalForm(traversal);
@@ -124,6 +147,7 @@ public abstract class AddVertexTest extends AbstractGremlinTest {
@Test
@LoadGraphWith(MODERN)
@FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
+ @FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_PROPERTY)
public void g_addVXlabel_person_name_stephenX() {
final Traversal<Vertex, Vertex> traversal = get_g_addVXlabel_person_name_stephenX();
printTraversalForm(traversal);
@@ -154,6 +178,11 @@ public abstract class AddVertexTest extends AbstractGremlinTest {
}
@Override
+ public Traversal<Vertex, Vertex> get_g_V_hasXname_markoX_propertyXfriendWeight_outEXknowsX_weight_sum__acl_privateX() {
+ return g.V().has("name", "marko").property("friendWeight", __.outE("knows").values("weight").sum(), "acl", "private");
+ }
+
+ @Override
public Traversal<Vertex, Vertex> get_g_V_addVXlabel_animal_age_0X() {
return g.V().addV(T.label, "animal", "age", 0);
}
[8/8] incubator-tinkerpop git commit: updated CHANGELOG with latest
AddXXXStep work.
Posted by ok...@apache.org.
updated CHANGELOG with latest AddXXXStep work.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/8d975818
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/8d975818
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/8d975818
Branch: refs/heads/master
Commit: 8d975818d679240275ee9f1c8c850efc57937bc4
Parents: e51a107
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Wed Aug 26 11:03:20 2015 -0600
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Wed Aug 26 11:03:20 2015 -0600
----------------------------------------------------------------------
CHANGELOG.asciidoc | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/8d975818/CHANGELOG.asciidoc
----------------------------------------------------------------------
diff --git a/CHANGELOG.asciidoc b/CHANGELOG.asciidoc
index be25cf3..6218958 100644
--- a/CHANGELOG.asciidoc
+++ b/CHANGELOG.asciidoc
@@ -26,6 +26,9 @@ image::https://raw.githubusercontent.com/apache/incubator-tinkerpop/master/docs/
TinkerPop 3.1.0 (NOT OFFICIALLY RELEASED YET)
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+* Added `Parameters` object to allow for the parameters of a step to be retrieved at runtime via a traversal.
+* Redesigned (though backwards compatible) `AddEdgeStep`, `AddVertexStep`, and `AddPropertyStep` (and respective `GraphTraversal` API).
+* Added `GraphTraversalSource.inject()` so users can spawn a traverser with non-graph objects.
* `GraphStep` can now take a single argument `Collection` which is either elements or element ids (i.e. `g.V([1,2,3])` is supported now).
* Added `LoopsStep` to make the loop counter accessible within `repeat()`, `until()` and `emit()`.
* Gephi Plugin no longer requires manual insert of `store` steps to visualize a traversal.
[7/8] incubator-tinkerpop git commit: Merge branch
'mutating_traverser'
Posted by ok...@apache.org.
Merge branch 'mutating_traverser'
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/e51a1074
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/e51a1074
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/e51a1074
Branch: refs/heads/master
Commit: e51a107448a0321d955196f146bb68df79ad51d8
Parents: 95ff755 7beb369
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Wed Aug 26 11:01:16 2015 -0600
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Wed Aug 26 11:01:16 2015 -0600
----------------------------------------------------------------------
docs/src/the-traversal.asciidoc | 46 ++--
.../process/traversal/Parameterizing.java | 32 +++
.../traversal/dsl/graph/GraphTraversal.java | 242 +++++++++++++++++--
.../dsl/graph/GraphTraversalSource.java | 44 +++-
.../gremlin/process/traversal/dsl/graph/__.java | 49 +++-
.../process/traversal/step/Mutating.java | 3 +
.../process/traversal/step/filter/DropStep.java | 4 +
.../process/traversal/step/map/AddEdgeStep.java | 123 ++++------
.../traversal/step/map/AddVertexStartStep.java | 73 ++++--
.../traversal/step/map/AddVertexStep.java | 69 ++++--
.../step/sideEffect/AddPropertyStep.java | 130 +++++-----
.../process/traversal/step/util/Parameters.java | 118 +++++++++
.../strategy/decoration/ElementIdStrategy.java | 44 +---
.../strategy/decoration/PartitionStrategy.java | 30 +--
.../tinkerpop/gremlin/structure/Graph.java | 2 +-
.../traversal/dsl/graph/GraphTraversalTest.java | 2 +-
.../traversal/step/map/AddEdgeStepTest.java | 10 +-
.../ElementIdStrategyTraverseTest.java | 38 ++-
.../strategy/decoration/EventStrategyTest.java | 15 +-
.../PartitionStrategyTraverseTest.java | 64 ++---
.../SubgraphStrategyTraverseTest.java | 20 +-
.../verification/ReadOnlyStrategyTest.java | 17 +-
.../traversal/step/map/GroovyAddEdgeTest.groovy | 26 ++
.../step/map/GroovyAddVertexTest.groovy | 29 ++-
.../process/traversal/step/map/AddEdgeTest.java | 196 +++++++++++++--
.../traversal/step/map/AddVertexTest.java | 106 +++++++-
.../ElementIdStrategyProcessTest.java | 29 ++-
.../decoration/EventStrategyProcessTest.java | 42 ++--
.../PartitionStrategyProcessTest.java | 34 +--
.../ReadOnlyStrategyProcessTest.java | 12 +-
.../tinkergraph/structure/TinkerGraphTest.java | 8 +-
31 files changed, 1196 insertions(+), 461 deletions(-)
----------------------------------------------------------------------
[5/8] incubator-tinkerpop git commit: add
GraphTraversalSource.inject().
Posted by ok...@apache.org.
add GraphTraversalSource.inject().
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/0d0ba7b5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/0d0ba7b5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/0d0ba7b5
Branch: refs/heads/master
Commit: 0d0ba7b5c9b2c758358774648f5d181efb40e74e
Parents: 085cd16
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Tue Aug 25 20:06:28 2015 -0600
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Tue Aug 25 20:06:28 2015 -0600
----------------------------------------------------------------------
.../process/traversal/dsl/graph/GraphTraversalSource.java | 9 +++++++++
.../gremlin/tinkergraph/structure/TinkerGraphTest.java | 5 +++--
2 files changed, 12 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/0d0ba7b5/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalSource.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalSource.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalSource.java
index 799aca3..ddb8076 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalSource.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/dsl/graph/GraphTraversalSource.java
@@ -90,6 +90,10 @@ public class GraphTraversalSource implements TraversalSource {
return traversal;
}
+ public <S> GraphTraversal<S, S> inject(S... starts) {
+ return (GraphTraversal<S, S>) this.generateTraversal().inject(starts);
+ }
+
/**
* @deprecated As of release 3.1.0, replaced by {@link #addV()}
*/
@@ -244,6 +248,11 @@ public class GraphTraversalSource implements TraversalSource {
this.withPaths = withPaths;
}
+ public <S> GraphTraversal<S, S> inject(S... starts) {
+ this.traversal.inject(starts);
+ return ((this.withPaths) ? this.traversal.addStep(new PathIdentityStep<>(this.traversal)) : this.traversal);
+ }
+
/**
* @deprecated As of release 3.1.0, replaced by {@link #addV()}
*/
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/0d0ba7b5/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/structure/TinkerGraphTest.java
----------------------------------------------------------------------
diff --git a/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/structure/TinkerGraphTest.java b/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/structure/TinkerGraphTest.java
index 194fbe5..96815ac 100644
--- a/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/structure/TinkerGraphTest.java
+++ b/tinkergraph-gremlin/src/test/java/org/apache/tinkerpop/gremlin/tinkergraph/structure/TinkerGraphTest.java
@@ -169,9 +169,10 @@ public class TinkerGraphTest {
graph.createIndex("name",Vertex.class);
graph.io(GraphMLIo.build()).readGraph("/Users/marko/software/tinkerpop/tinkerpop3/data/grateful-dead.xml");*/
//System.out.println(g.V().properties().key().groupCount().next());
- TinkerGraph graph = TinkerFactory.createModern();
+ TinkerGraph graph = TinkerGraph.open();
GraphTraversalSource g = graph.traversal(GraphTraversalSource.standard());
- g.V().as("a").addV("animal").property("age",select("a").by("age")).forEachRemaining(System.out::println);
+ g.inject("alice", "bob", "charlie").as("a").addV("person").property("name", select("a")).forEachRemaining(System.out::println);
+ g.V().valueMap().forEachRemaining(System.out::println);
/*final List<Supplier<GraphTraversal<?,?>>> traversals = Arrays.asList(
() -> g.V().out().as("v").match(
__.as("v").outE().count().as("outDegree"),