Gremlin查询最后一个值的groupcount

Question

我有一个titan图，有两组顶点，一个用于用户ID，另一个用于产品。用户ID和产品顶点之间的边缘包含购买产品的“日期”。我正在寻找一个小精灵查询，它可以根据上次购买的产品为我提供用户ID的groupcount

例如，如果有如下数据

UserID,Date,Product
A,2016-01-01,'Razor'
A,2016-01-02,'Toothpaste'
B,2016-02-01,'Toothpaste'
B,2016-02-02,'Razor'
C,2016-01-04,'Toothpaste'

我正在寻找如下输出

Product, Count
'Toothpaste',2
'Razor',1

会感谢任何帮助。

Answer 1

以下查询适用于联机事务处理和OLAP，并且不会触及超过必要的顶点：

g.V().hasLabel("User").
  local(outE("purchased").order().by("date", decr).limit(1)).inV().
  groupCount().by("name")

此外，当您在日期创建以顶点为中心的索引时，Titan可以完美地优化此查询。

Answer 2

此解决方案适用于您的示例数据：

g、 V（）.hasLabel（'Product'）。as（'p'）。inE（'Purchase'）。order（）。by（'Date'，decr）.outV（）.dedup（）.select（'p'）.groupCount（）.by（'Name'）

这是算法：

• 从产品开始
• 遍历到购买边缘
• 按日期降序排列边缘
• 遍历到用户
• 重复数据消除用户；由于排序，每个用户只保留最近的边缘
• 跳回产品
• 按产品名称分组计数

下面是一个Gremlin控制台转储，显示了它的实际情况：

gremlin> graph = TinkerGraph.open()
==>tinkergraph[vertices:0 edges:0]
gremlin> a = graph.addVertex(T.label, 'User', 'UserID', 'A')
==>v[0]
gremlin> b = graph.addVertex(T.label, 'User', 'UserID', 'B')
==>v[2]
gremlin> c = graph.addVertex(T.label, 'User', 'UserID', 'C')
==>v[4]
gremlin> r = graph.addVertex(T.label, 'Product', 'Name', 'Razor')
==>v[6]
gremlin> t = graph.addVertex(T.label, 'Product', 'Name', 'Toothpaste')
==>v[8]
gremlin> a.addEdge('Purchase', r, 'Date', new Date(2016, 0, 1))
==>e[10][0-Purchase->6]
gremlin> a.addEdge('Purchase', t, 'Date', new Date(2016, 0, 2))
==>e[11][0-Purchase->8]
gremlin> b.addEdge('Purchase', t, 'Date', new Date(2016, 1, 1))
==>e[12][2-Purchase->8]
gremlin> b.addEdge('Purchase', r, 'Date', new Date(2016, 1, 2))
==>e[13][2-Purchase->6]
gremlin> c.addEdge('Purchase', t, 'Date', new Date(2016, 0, 4))
==>e[14][4-Purchase->8]
gremlin> g = graph.traversal()
==>graphtraversalsource[tinkergraph[vertices:5 edges:5], standard]
gremlin> g.V().hasLabel('Product').as('p').inE('Purchase').order().by('Date', decr).outV().dedup().select('p').groupCount().by('Name')
==>[Toothpaste:2,Razor:1]