gremlin sideEffect 的替代品，因为 Neptune 不支持它？

Question

在 AWS Neptune 中，我试图通过计算余弦相似度来创建用户顶点之间的相似边，如 Daniel Kuppitz 此处所述——https://gist.github.com/dkuppitz/79e0b009f0c9ae87db5a#file-cosim-groovy-L368——gremlin 的 sideEffect 提供了一个有用的闭包，它允许进行一些数学运算获取相似度分数并将此值写入每个“相似度”边缘。唉，海王星不支持副作用。我正在寻找一种在不使用 sideEffect 的情况下在单个 gremlin 查询中运行以下示例中的注释部分的方法。感谢您的帮助！

g.V().match(
__.as("u1").outE("rated").as("r1"),
__.as("r1").inV().as("m"),
__.as("m").inE("rated").as("r2"),
__.as("r2").outV().as("u2")
).where("u1", neq("u2")).
group().by(select("u1","u2")).
by(select("r1","r2").by("rating")).
unfold().
as("kv").
select(keys).
addE("similarity").from("u1").to("u2").as("e").
// sideEffect {
//   def r = it.get("kv").getValue()
//   def xyDotProduct = r.collect {it.r1*it.r2}.sum()
//   def xLength = Math.sqrt(r.collect {it.r1*it.r1}.sum())
//   def yLength = Math.sqrt(r.collect {it.r2*it.r2}.sum())
//   def similarity = xyDotProduct / (xLength * yLength)
//   it.get().property("similarity", similarity)
// }.iterate()

Answer 1

Amazon Neptune 支持 sideEffect 步骤，但不支持在任何步骤中使用 Groovy 闭包。我相信使用math 和project 步骤的组合可以实现示例中显示的相同效果。这是一个有点相似（就复杂性而言）计算Haversine Greate Circle距离的链接。也许您可以使用类似于this one from Practical Gremlin 的方法。

start = 'SFO'
stop = 'NRT'

g.withSideEffect("rdeg", 0.017453293).
  withSideEffect("gcmiles",3956).
  V().has('code',start).as('src').
  V().has('code',stop).as('dst').
  select('src','dst').
    by(project('lat','lon').
         by('lat').
         by('lon')).
  as('grp').
  project('ladiff','lgdiff','lat1','lon1','lat2','lon2').
    by(project('la1','la2').
         by(select('grp').select('src').select('lat')).
         by(select('grp').select('dst').select('lat')).
       math('(la2 - la1) * rdeg')).
    by(project('lg1','lg2').
         by(select('grp').select('src').select('lon')).
         by(select('grp').select('dst').select('lon')).
       math('(lg2 - lg1) * rdeg')).
    by(select('grp').select('src').select('lat')).
    by(select('grp').select('src').select('lon')).
    by(select('grp').select('dst').select('lat')).
    by(select('grp').select('dst').select('lon')).
  math('(sin(ladiff/2))^2 + cos(lat1*rdeg) * cos(lat2*rdeg) * (sin(lgdiff/2))^2').
  math('gcmiles * (2 * asin(sqrt(_)))')

这种方法不是在闭包内使用变量，而是使用project 来有效地创建仍然可以传递给math 步骤的相同变量。