如何只发出完整的路径或以重复循环终止？

Question

​

​

我的图看起来像上图。它是光通信网络的简化形式。每个顶点传递一种颜色。当两种颜色结合在一起("Mux")时，它就会产生新的颜色并发出新的光。在远端，颜色被分离并传递给相应的顶点。Mux、demux和transmit(“直通”)被捕获为edge。根据通风口图形成新的颜色。

如果我从一种颜色开始(例如“红色”)，那么我必须只遍历有红色阴影(R1，R2)或红色阴影(D1，D2，P1)的边。

例如，如果我从R1开始，那么我可以遍历R1、D1、D2、P1、R2。它有另一个路径R1、D1、D2、P1、K1、R2，但它无效。因为K1没有红色阴影。

下面的查询运行得很好。我在遍历"mux“边缘时存储颜色。并使用此颜色来选择demux边缘。

 g.V().hasLabel("R1").
                repeat(choose(values("type")).
                        option("mux", aggregate(local, "colors").by("color").inV()).
                        option("demux", filter(values("color").as("c").
                                where("c", new P(new BitiseAndPredicate(), "colors")).
                                by().
                                by(unfold().limit(1))
                        ).inV()).
                        option("stright", __.inV()).simplePath()).
                until(hasLabel("R2")).
                path().by(label()).toList();

对于输入"R1“到"R2”，它工作得很好。R1、tx、D1、tx、D2、tx、P1、tx、R2

对于"Y1“到"Y2”，它返回empty。这是正确的，因为从G1到Y1没有边。

我想对查询进行更改。如果不能到达目的地，则打印到到达目的地为止，本例中为Y1、tx、D1、tx、D2、tx、G1

我使用emit()。但它会打印路径上的所有路径组合。

g.V().hasLabel("R1").
                repeat(choose(values("type")).
                        option("mux", aggregate(local, "colors").by("color").inV()).
                        option("demux", filter(values("color").as("c").
                                where("c", new P(new BitiseAndPredicate(), "colors")).
                                by().
                                by(unfold().limit(1))
                        ).inV()).
                        option("stright", __.inV()).simplePath()).
                until(hasLabel("R2")).emit().
                path().by(label()).toList();

如果是简单的遍历，那么我可以使用emit(out().count().is(eq('0')))。但在这种情况下，最后一条边有更多的边，但它不符合我的"mux & demux“条件。我不能在“重复”步骤中重用相同的条件。实际的实现将更加复杂。

如果满足条件或重复步骤没有返回任何顶点，有没有办法发出路径。

以下是Java代码

import org.apache.tinkerpop.gremlin.process.traversal.P;
import org.apache.tinkerpop.gremlin.process.traversal.Path;
import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversal;
import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversalSource;
import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.__;
import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.apache.tinkerpop.gremlin.util.function.Lambda;
import org.janusgraph.core.*;
import org.janusgraph.core.schema.JanusGraphManagement;

import java.util.ArrayList;
import java.util.List;

import static org.apache.tinkerpop.gremlin.process.traversal.P.eq;
import static org.apache.tinkerpop.gremlin.process.traversal.P.without;
import static org.apache.tinkerpop.gremlin.process.traversal.Scope.local;
import static org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.__.*;
import static org.janusgraph.core.Multiplicity.MULTI;

public class ColourTraversal
{
    public static void main( String[] args )
    {

        //External db
        GraphTraversalSource g =null;

        //inmemory db
        JanusGraph graph = JanusGraphFactory.build().set("storage.backend", "inmemory").open();
        g = graph.traversal();



        try
        {


           populateData(g);
           g.tx().commit();

            printPath(g, "R1", "R2");

            System.out.println();
            printPath(g, "Y1", "Y2");



            g.close();
        } catch (Exception e)
        {
            e.printStackTrace();
        }

    }

    private static void printPath(GraphTraversalSource g, String start, String end)
    {


        List<Path> pathList = g.V().hasLabel(start).
                repeat(repeatStep().simplePath()).
                emit(hasLabel(end)).
                path().by(label()).toList();


        for (Path path : pathList)
        {
            for (int i = 0; i < path.size(); i++)
            {
                String label = path.get(i);
                System.out.println(label);
            }
        }
    }



    private static GraphTraversal<?, Vertex> repeatStep()
    {

        GraphTraversal<?, ?> repeatStepTrav =
                outE("tx").choose(values("type")).
                        option("mux", aggregate(local, "colors").by("color").inV()).
                        option("demux", filter(values("color").as("c").
                                where("c", new P(new BitiseAndPredicate(), "colors")).
                                by().
                                by(unfold().limit(1))
                        ).inV()).
                        option("stright", __.inV());

        return (GraphTraversal<Vertex, Vertex>) repeatStepTrav;
    }


    private static void populateData(GraphTraversalSource g)
    {
        Vertex r1 = g.addV("R1").next();
        Vertex r2 = g.addV("R2").next();

        Vertex d1 = g.addV("D1").next();
        Vertex d2 = g.addV("D2").next();

        Vertex g1 = g.addV("G1").next();

        Vertex b1 = g.addV("B1").next();
        Vertex b2 = g.addV("B2").next();
        Vertex b3 = g.addV("B3").next();

        Vertex y1 = g.addV("Y1").next();


        Vertex p1 = g.addV("P1").next();

        addEdge(g, r1, d1, "mux", 4);
        addEdge(g, y1, d1, "mux", 2);
        addEdge(g, b1, d1, "mux", 1);

        addEdge(g, d1, d2, "stright", 7);

        addEdge(g, g1, d2, "mux", 3);
        addEdge(g, p1, d2, "mux", 5);

        addEdge(g, b2, g1, "mux", 1);



        addEdge(g, b3,p1,  "mux", 1);
        addEdge(g, r2,p1,  "mux", 4);



        addEdge(g, d1, r1, "demux", 4);
        addEdge(g, d1, y1, "demux", 2);
        addEdge(g, d1, b1, "demux", 1);

        addEdge(g, d2, d1, "stright", 7);

        addEdge(g, d2,g1,  "demux", 3);
        addEdge(g,  d2,p1, "demux", 5);

        addEdge(g, g1,b2,  "demux", 1);



        addEdge(g,  p1,b3, "demux", 1);
        addEdge(g,  p1,r2, "demux", 4);



        Vertex k1 = g.addV("K1").next();

        addEdge(g, p1, k1, "demux", 0);
        addEdge(g, k1, r2, "demux", 0);
        addEdge(g, k1, p1, "mux", 0);
        addEdge(g, r2, k1, "mux", 0);


//         Vertex y2 = g.addV("Y2").next();
//         addEdge(g, y2, g1, "mux", 2);
//           addEdge(g,  g1,y2, "demux", 2);

    }



    private static void addEdge(GraphTraversalSource g, Vertex source, Vertex destination,String type,int color) {
        GraphTraversal t = g.V(source).addE("tx").to(destination).property("type", type).property("color", color);


        t.next();
    }
}

import java.util.function.BiPredicate;

public class BitisetAndPredicate implements BiPredicate {
    @Override
    public boolean test(Object o, Object o2) {
        int left = (int) o;
        int right = (int) o2;
        return (left & right) == right;
    }

}

Answer 1

除了使用emit()步骤之外，您还可以向until()步骤添加析取条件，以测试没有更多外边的路径。

下面的gremlin控制台中的会话使用了tinkerpop modern示例图形，展示了如何：

graph = TinkerFactory.createModern()
g = graph.traversal()

// Your old query
gremlin> g.V(1).repeat(out()).until(has("name", "ripple")).path()
==>[v[1],v[4],v[5]]

// A query with additional condition to stop the repeat
gremlin> g.V(1).repeat(out()).until(or(has("name", "ripple"), out().count().is(eq(0)))).path()
==>[v[1],v[3]]
==>[v[1],v[2]]
==>[v[1],v[4],v[5]]
==>[v[1],v[4],v[3]]