如何合并两个含独立起始步骤的Gremlin查询为单个遍历？

需要实现一个Java方法createUnion，将两个独立的Gremlin查询（GraphTraversal类型的t1和t2）合并为单个遍历。已知条件：

• t1和t2均包含独立起始步骤（.V()或.E()）
• t1起始为.V()时，t2可能为.E()，反之亦然

已尝试的方案及问题 #

方案1：直接基于t1调用union步骤 #

代码示例：

t1.union(
    __.identity(),
    t2
)

问题：union步骤会针对t1的每个输入元素执行t2，这不符合合并两个独立查询的预期——我们需要两个查询各自独立执行后合并结果，而非基于t1的元素重复执行t2。

方案2：使用inject步骤 #

代码示例：

t1.inject(t2.toList().toArray(new Object[0]))

问题：

1. t2会在查询构建阶段被立即求值，无法延迟到查询执行阶段计算
2. t2中定义的标签、副作用等无法在最终遍历结果中生效

最优解决方案 #

正确的做法是从一个空遍历起点出发，用union包裹两个独立查询，确保它们各自独立执行。

实现代码 #

import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversal;
import static org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.__.*;

public class GremlinUtils {
    public static <S, E> GraphTraversal<S, E> createUnion(GraphTraversal<?, E> t1, GraphTraversal<?, E> t2) {
        // 以空遍历为起点，合并两个独立查询
        return __.<S>start().union(t1, t2);
    }
}

方案说明 #

• 通过__.<S>start()创建空起始遍历，让union的两个子遍历t1、t2完全独立执行，各自从自身的.V()/.E()步骤开始
• 完整保留t1和t2中的标签、副作用等所有定义，因为两个子遍历都是完整独立的查询单元
• 实现延迟求值，t1和t2的执行会推迟到合并后的遍历提交到图数据库时才进行，避免提前求值的问题

内容的提问来源于stack exchange，提问作者Martin Häusler