Skip to content

Commit

Permalink
Updated to latest TP3 release.
Browse files Browse the repository at this point in the history
  • Loading branch information
mbroecheler committed Jan 19, 2015
1 parent 0ec8e8f commit a43a3a7
Show file tree
Hide file tree
Showing 6 changed files with 6 additions and 6 deletions.
2 changes: 1 addition & 1 deletion pom.xml
Expand Up @@ -59,7 +59,7 @@
</scm> </scm>
<properties> <properties>
<titan.compatible.versions /> <titan.compatible.versions />
<tinkerpop.version>3.0.0-SNAPSHOT</tinkerpop.version> <tinkerpop.version>3.0.0.M7</tinkerpop.version>
<junit.version>4.11</junit.version> <junit.version>4.11</junit.version>
<mrunit.version>1.1.0</mrunit.version> <mrunit.version>1.1.0</mrunit.version>
<cassandra.version>2.0.8</cassandra.version> <cassandra.version>2.0.8</cassandra.version>
Expand Down
Expand Up @@ -55,7 +55,7 @@ public static Traversal<Vertex,Edge> getReverseElementTraversal(final MessageSco
final Vertex start, final Vertex start,
final TitanTransaction graph) { final TitanTransaction graph) {
Traversal<Vertex,Edge> incident = scope.getIncidentTraversal().get(); Traversal<Vertex,Edge> incident = scope.getIncidentTraversal().get();
Step<Vertex,?> startStep = TraversalHelper.getStart(incident); Step<Vertex,?> startStep = TraversalHelper.getStart(incident.asAdmin());
assert startStep instanceof VertexStep; assert startStep instanceof VertexStep;
((VertexStep) startStep).reverse(); ((VertexStep) startStep).reverse();


Expand Down
Expand Up @@ -114,7 +114,7 @@ public void getQueries(QueryContainer queries) {
} else { } else {
assert scope instanceof MessageScope.Local; assert scope instanceof MessageScope.Local;
Traversal<Vertex,Edge> incident = FulgoraUtil.getTraversal((MessageScope.Local) scope,queries.getTransaction()); Traversal<Vertex,Edge> incident = FulgoraUtil.getTraversal((MessageScope.Local) scope,queries.getTransaction());
TitanVertexStep<Vertex> startStep = (TitanVertexStep<Vertex>) TraversalHelper.getStart(incident); TitanVertexStep<Vertex> startStep = (TitanVertexStep<Vertex>) TraversalHelper.getStart(incident.asAdmin());
startStep.reverse(); startStep.reverse();
QueryContainer.QueryBuilder qb = queries.addQuery(); QueryContainer.QueryBuilder qb = queries.addQuery();
startStep.makeQuery(qb); startStep.makeQuery(qb);
Expand Down
Expand Up @@ -87,7 +87,7 @@ public static void foldInHasContainer(final HasStepFolder titanStep, final Trave
} }
} }


public static void addLabeledStepAsIdentity(Step<?,?> currentStep, final Traversal<?, ?> traversal) { public static void addLabeledStepAsIdentity(Step<?,?> currentStep, final Traversal.Admin<?, ?> traversal) {
currentStep.getLabel().ifPresent(label -> { currentStep.getLabel().ifPresent(label -> {
final IdentityStep identityStep = new IdentityStep<>(traversal); final IdentityStep identityStep = new IdentityStep<>(traversal);
identityStep.setLabel(label); identityStep.setLabel(label);
Expand Down
Expand Up @@ -34,7 +34,7 @@ public void apply(final Traversal.Admin<?, ?> traversal, final TraversalEngine e
final GraphStep<?> originalGraphStep = (GraphStep) startStep; final GraphStep<?> originalGraphStep = (GraphStep) startStep;
if (originalGraphStep.getIds()==null || originalGraphStep.getIds().length==0) { if (originalGraphStep.getIds()==null || originalGraphStep.getIds().length==0) {
final TitanGraphStep<?> titanGraphStep = new TitanGraphStep<>(originalGraphStep); final TitanGraphStep<?> titanGraphStep = new TitanGraphStep<>(originalGraphStep);
TraversalHelper.replaceStep(startStep, titanGraphStep, traversal); TraversalHelper.replaceStep(startStep, (Step)titanGraphStep, traversal);


HasStepFolder.foldInHasContainer(titanGraphStep,traversal); HasStepFolder.foldInHasContainer(titanGraphStep,traversal);
HasStepFolder.foldInOrder(titanGraphStep,traversal,traversal,titanGraphStep.returnsVertices()); HasStepFolder.foldInOrder(titanGraphStep,traversal,traversal,titanGraphStep.returnsVertices());
Expand Down
Expand Up @@ -66,7 +66,7 @@ public static TitanTransaction getTx(Traversal<?,?> traversal) {
if (traversal instanceof FulgoraElementTraversal) { if (traversal instanceof FulgoraElementTraversal) {
tx = ((FulgoraElementTraversal)traversal).getGraph(); tx = ((FulgoraElementTraversal)traversal).getGraph();
} else { } else {
Step startStep = TraversalHelper.getStart(traversal); Step startStep = TraversalHelper.getStart(traversal.asAdmin());
if (startStep instanceof GraphStep) { if (startStep instanceof GraphStep) {
Graph graph = ((GraphStep)startStep).getGraph(Graph.class); Graph graph = ((GraphStep)startStep).getGraph(Graph.class);
if (graph instanceof TitanTransaction) tx = (TitanTransaction)graph; if (graph instanceof TitanTransaction) tx = (TitanTransaction)graph;
Expand Down

0 comments on commit a43a3a7

Please sign in to comment.