java - 如何在java中使用Gremlin PipeLine副作用

Question

我想知道如何实现以下 gremlin 查询g.V.has("mgrNo",T.neq,"0").sideEffect{g.V.has("empNo",it.mgrNo).next( ).addEdge("manages",it)} 在 java 中使用 GremlinPipeLine 。

从 .next() 开始实现时，我感到很困惑。

GremlinPipeline pipe = new GremlinPipeline(graph).V().has("mgrNo",T.neq,0).sideEffect(new PipeFunction<Vertex, Object>(){
    @Override
    public Object compute(Vertex vertex) {
        @SuppressWarnings("rawtypes")
        GremlinPipeline pipeline = (GremlinPipeline) new GremlinPipeline(graph).V().has("empNo", vertex.getProperty("mgrNo")).next();
        //code here 
        return pipeline;
    }
});

Answer 1

你几乎已经拥有它了，实际上你已经有太多代码了。这应该适合你:

new GremlinPipeline(graph).V().has("mgrNo",T.neq,0).sideEffect(new PipeFunction<Vertex, Object>(){
    @Override
    public Object compute(Vertex vertex) {
        @SuppressWarnings("rawtypes")
        Vertex mgr = (Vertex) new GremlinPipeline(graph).V().has("empNo", vertex.getProperty("mgrNo")).next();
        return mgr.addEdge("manages", vertex);
    }
}).iterate();