根据从不同边缘的属性中导出的信息过滤边缘

Question

我正在尝试使用 Tinkerpop3 将火车时刻表表示为图表。该图的节点是火车站，边是 "schedule elements"，其中包含有关从一个车站到另一个车站的火车的所有信息。我目前正在努力制定图形查询，以查找与从不同边的属性派生的时间 window 内离开车站的火车相对应的所有边。

为了说明我要解决的问题，我设置了一个小玩具图：

graph = TinkerGraph.open()

g = graph.traversal()

g.addV().property('name', 'London Euston').
  addV().property('name', 'Milton Keynes').
  addV().property('name', 'Stoke-on-Trent').
  addV().property('name', 'Stockport').
  addV().property('name', 'Manchester Piccadilly')

  schedule = [['London Euston', 'Milton Keynes', 
               'T1', 1509537600000, 1509539400000],
              ['Milton Keynes', 'Stoke-on-Trent', 
               'T1', 1509539460000, 1509541200000],
              ['Stoke-on-Trent', 'Stockport', 
               'T1', 1509541260000, 1509543000000],
              ['Stockport', 'Manchester Piccadilly', 
               'T1', 1509543060000, 1509544800000],
              ['London Euston', 'Milton Keynes', 
               'T2', 1509537900000, 1509540000000],
              ['Milton Keynes', 'Stoke-on-Trent', 
               'T2', 1509540060000, 1509542100000],
              ['Stoke-on-Trent', 'Stockport', 
               'T2', 1509542160000, 1509544200000],
              ['Stockport', 'Manchester Piccadilly', 
               'T2', 1509544260000, 1509546600000],
              ['London Euston', 'Milton Keynes', 
               'T3', 1509548400000, 1509550200000],
              ['Milton Keynes', 'Stoke-on-Trent', 
               'T3', 1509550260000, 1509552000000],
              ['Stoke-on-Trent', 'Stockport', 
               'T3', 1509552060000, 1509553800000],
              ['Stockport', 'Manchester Piccadilly', 
               'T3', 1509553860000, 1509555600000]]

for(scheduleInfo in schedule)
{
  v1 = g.V().has('name', scheduleInfo[0]).next()
  v2 = g.V().has('name', scheduleInfo[1]).next()

  v1.addEdge('Schedule', v2, 
             'trainID', scheduleInfo[2], 
             'outTime', scheduleInfo[3], 
             'inTime', scheduleInfo[4])
}

该图由从伦敦到曼彻斯特的三列火车的（编造）时刻表组成。边具有三个属性：

trainID: 火车ID
outTime: 出发节点出发时间
inTime：进入节点到达时间

所有时间都存储为以毫秒为单位的 UNIX 时间戳。我想从图表中找出的一件事是：

对于火车'T1'出发的所有车站，还有哪些火车也从这些车站出发？

事实证明这是一个相当简单的 Gremlin 查询

g.E().has('trainID','T1').as('e1').
outV().as('station').outE().as('e2').
path().by('trainID').by('name')

我现在正在苦苦挣扎的查询如下：

对于火车'T1'出发的所有车站，在火车'T1'的plus/minus 15分钟内有多少辆火车离开同一车站？

到目前为止我能想到的最接近的答案是：

g.E().has('trainID','T1').as('e1').
outV().as('station').
outE().as('e2').
path().
filter{it.get().e2.outTime > (it.get().e1.outTime - 60*15*1000L)}.
filter{it.get().e2.outTime < (it.get().e1.outTime + 60*15*1000L)}

此查询为我提供了我想要的所有路径，但它使用了 lambda 步骤，这是 TinkerPop3 文档明确反对的做法。我想知道是否有不同的方式来编写不使用 lambda 步骤的查询。任何帮助将不胜感激。

Answer 1

基本查询是：

g.E().has('trainID','T1').
  sack(assign).
    by('outTime').
  outV().as('station').
  outE().has('trainID', neq('T1')).
  sack(minus).
    by('outTime').
  filter(sack().is(between(-60*15*1000L, 60*15*1000L)))

添加一些路径标签以创建更具可读性的输出：

gremlin> g.E().has('trainID','T1').as('e1').
           sack(assign).
             by('outTime').
           outV().as('station').
           outE().has('trainID', neq('T1')).as('e2').
           sack(minus).
             by('outTime').
           filter(sack().is(between(-60*15*1000L, 60*15*1000L))).
           select('station','e1','e2').each {
             println "${it.get('station').value('name')}"
             println "* T1 departure: ${new Date(it.get('e1').value('outTime'))}"
             println "* ${it.get('e2').value('trainID')} departure: ${new Date(it.get('e2').value('outTime'))}\n"
           }; []
London Euston
* T1 departure: Wed Nov 01 05:00:00 MST 2017
* T2 departure: Wed Nov 01 05:05:00 MST 2017

Milton Keynes
* T1 departure: Wed Nov 01 05:31:00 MST 2017
* T2 departure: Wed Nov 01 05:41:00 MST 2017

Stoke-on-Trent
* T1 departure: Wed Nov 01 06:01:00 MST 2017
* T2 departure: Wed Nov 01 06:16:00 MST 2017

根据从不同边缘的属性中导出的信息过滤边缘

Filtering edges based on information derived from properties of different edges

gremlin

tinkerpop3