为什么这个 Gremlin 遍历返回空？

Question

我有一个 Gremlin 顶点，它具有设置值属性 emails 和 phones。作为我的更新逻辑的一部分，我正在尝试删除并重新创建这些属性：

String key = ThreadLocalRandom.current().nextInt()
def dropped = vtx.as(key).properties('emails', 'phones').drop().<Vertex>select(key)

我的期望是顶点将被as标记，然后我遍历属性并删除它们，然后使用select返回顶点进行进一步处理。但是，执行此操作总是会导致空遍历。

我已经能够让遍历返回一个结果，而不是说

def dropped = vtx.sideEffect(__.properties('emails', 'phones').drop())

但我想确保在继续之前严格删除这些属性，然后我会继续重新插入它们。

为什么原始遍历的行为不像我预期的那样？对于sideEffect 版本，是否需要添加barrier() 以确保正确性，如果需要，是否足够？

Answer 1

请注意，drop() 是一个过滤步骤，因此它不会产生遍历器。进入其中的所有内容都将从流中删除。这样，您的select() 永远不会被调用。您可以通过profile() 看到这一点：

gremlin> g.V().as('a').drop().select('a').profile()
==>Traversal Metrics
Step                                                               Count  Traversers       Time (ms)    % Dur
=============================================================================================================
TinkerGraphStep(vertex,[])@[a]                                       808         808           1.922    19.04
DropStep                                                                                       8.138    80.60
SelectOneStep(last,a)                                                                          0.010     0.10
NoOpBarrierStep(2500)                                                                          0.026     0.26
                                            >TOTAL                     -           -          10.097        -

您使用sideEffect() 的方法是做您想做的事情的正确方法。副作用遍历应该在继续之前迭代完成，因此我希望当 sideEffect() 步骤完成时，遍历器通过它时会删除所有属性。