GremlinApache软件基金会下的Apache TinkerPop开发的图遍历语言和虚拟机。Gremlin适用于基于OLTP的图数据库以及基于OLAP的图处理器。Gremlin的函数式语言自动机基础使Gremlin能够自然地支持指令式声明式查询、主机语言不可知性、用户定义的领域特定语言、可扩展的编译器/优化器、单机和多机运行模型、混合深度和广度优先评估以及图灵完全性[2]

Gremlin
设计者Marko A. Rodriguez
实现者Apache软件基金会下的Apache TinkerPop
发行时间2009年,​15年前​(2009
当前版本
  • 2.6.0(2014年9月17日)[1]
编辑维基数据链接
操作系统跨平台
许可证Apache许可证
网站tinkerpop.apache.org/gremlin.html
派生副语言
Gremlin-Java8, Gremlin-Groovy, Gremlin-Python, Gremlin-Scala, Gremlin-Clojure, Gremlin-PHP, Gremlin-JavaScript, Gremlin-Typeset
启发语言
正则表达式, XPath, Ripple, SPARQL, SQL, Java/JVM

作为一个解释性的类比,Apache TinkerPop和Gremlin之于图数据库,就如同JDBCSQL之于关系型数据库。 同样,Gremlin遍历机与图计算的关系也类似于为Java虚拟机与通用计算之间的关系。[3]

历史

  • 2009-10-30 项目诞生,并被命名为“TinkerPop”
  • 2009-12-25 v0.1是第一个版本
  • 2011-05-21 v1.0发布
  • 2012-05-24 v2.0发布
  • 2015-01-16 TinkerPop成为Apache孵化器项目
  • 2015-07-09 v3.0.0 孵化版发布
  • 2016-05-23 Apache TinkerPop成为一个Apache顶级项目
  • 2016-07-18 v3.1.3和v3.2.1是第一次作为Apache TinkerPop发布的版本
  • 2017-12-17 v3.3.1发布
  • 2018-05-08 v3.3.3发布

供应商的一体化

Gremlin是Apache2许可的图遍历语言,可供图系统供应商使用。通常有两种类型的图系统供应商:OLTP图数据库和OLAP图处理器。下表概述了支持Gremlin的图系统供应商。

供应商 图系统
Neo4j 图数据库
OrientDB 图数据库
DataStax Enterprise(5.0+) 图数据库
Hadoop (Giraph) 图处理器
Hadoop (Spark) 图处理器
InfiniteGraph 图数据库
JanusGraph 图数据库
Cosmos DB 图数据库
Amazon Neptune 图数据库
Ontotext GraphDB Triplestore

图遍历示例

以下Gremlin-Groovy环境中的Gremlin查询和响应示例与MovieLens数据集的图表示有关。[4] 该数据集包括为电影评分的用户,每个用户都有各自的职业,每部电影都有一个或多个与之相关的类别,MovieLens图表架构详述如下。

user--rated[stars:0-5]-->movie
user--occupation-->occupation
movie--category-->category

简单遍历

gremlin> g.V().label().groupCount()
==>[occupation:21, movie:3883, category:18, user:6040]
gremlin> g.V().hasLabel('movie').values('year').min()
==>1919
gremlin> g.V().has('movie','name','Die Hard').inE('rated').values('stars').mean()
==>4.121848739495798

投影遍历

gremlin> g.V().hasLabel('category').as('a','b').
           select('a','b').
             by('name').
             by(inE('category').count())
==>[a:Animation, b:105]
==>[a:Children's, b:251]
==>[a:Comedy, b:1200]
==>[a:Adventure, b:283]
==>[a:Fantasy, b:68]
==>[a:Romance, b:471]
==>[a:Drama, b:1603]
==>[a:Action, b:503]
==>[a:Crime, b:211]
==>[a:Thriller, b:492]
==>[a:Horror, b:343]
==>[a:Sci-Fi, b:276]
==>[a:Documentary, b:127]
==>[a:War, b:143]
==>[a:Musical, b:114]
==>[a:Mystery, b:106]
==>[a:Film-Noir, b:44]
==>[a:Western, b:68]
gremlin> g.V().hasLabel('movie').as('a','b').
           where(inE('rated').count().is(gt(10))).
           select('a','b').
             by('name').
             by(inE('rated').values('stars').mean()).
           order().by(select('b'),decr).
           limit(10)
==>[a:Sanjuro, b:4.608695652173913]
==>[a:Seven Samurai (The Magnificent Seven), b:4.560509554140127]
==>[a:Shawshank Redemption, The, b:4.554557700942973]
==>[a:Godfather, The, b:4.524966261808367]
==>[a:Close Shave, A, b:4.52054794520548]
==>[a:Usual Suspects, The, b:4.517106001121705]
==>[a:Schindler's List, b:4.510416666666667]
==>[a:Wrong Trousers, The, b:4.507936507936508]
==>[a:Sunset Blvd. (a.k.a. Sunset Boulevard), b:4.491489361702127]
==>[a:Raiders of the Lost Ark, b:4.47772]

声明式模式匹配遍历

Gremlin支持类似于SPARQL的声明式图模式匹配。例如,下面的查询使用了Gremlin的match() 步骤。

gremlin> g.V().
           match(
             __.as('a').hasLabel('movie'),
             __.as('a').out('category').has('name','Action'),
             __.as('a').has('year',between(1980,1990)),
             __.as('a').inE('rated').as('b'),
             __.as('b').has('stars',5),
             __.as('b').outV().as('c'),
             __.as('c').out('occupation').has('name','programmer'),
             __.as('c').has('age',between(30,40))).
           select('a').groupCount().by('name').
           order(local).by(valueDecr).
           limit(local,10)
==>Raiders of the Lost Ark=26
==>Star Wars Episode V - The Empire Strikes Back=26
==>Terminator, The=23
==>Star Wars Episode VI - Return of the Jedi=22
==>Princess Bride, The=19
==>Aliens=18
==>Boat, The (Das Boot)=11
==>Indiana Jones and the Last Crusade=11
==>Star Trek The Wrath of Khan=10
==>Abyss, The=9

OLAP遍历

gremlin> g = graph.traversal(computer(SparkGraphComputer))
==>graphtraversalsource[hadoopgraph[gryoinputformat->gryooutputformat], sparkgraphcomputer]
gremlin> g.V().repeat(outE('rated').has('stars', 5).inV().
                 groupCount('m').by('name').
                 inE('rated').has('stars', 5).outV()).
               times(4).cap('m')
==>Star Wars Episode IV - A New Hope	  35405394353105332
==>American Beauty	  31943228282020585
==>Raiders of the Lost Ark	31224779793238499
==>Star Wars Episode V - The Empire Strikes Back  30434677119726223
==>Godfather, The	30258518523013057
==>Shawshank Redemption, The	28297717387901031
==>Schindler's List	27539336654199309
==>Silence of the Lambs, The	26736276376806173
==>Fargo	 26531050311325270
==>Matrix, The	 26395118239203191

Gremlin图遍历机

Gremlin是一个由指令集和执行引擎组成的虚拟机。下表在Gremlin和Java之间进行了类比。

Java生态系统 Gremlin生态系统
Apache Groovy编程语言 Gremlin-Groovy
Scala编程语言 Gremlin-Scala
Clojure编程语言 Gremlin-Clojure
Java编程语言 Gremlin-Java8
Java指令集 Gremlin步骤库
Java虚拟机 Gremlin遍历机

Gremlin步骤(指令集)

以下历是一个Gremlin遍历在Gremlin-Java8的方言。

g.V().as("a").out("knows").as("b").
  select("a","b").
    by("name").
    by("age")

Gremlin语言(即表达图遍历的流式接口)可以用任何支持函数组合和函数嵌套的宿主语言表示。由于这个简单的要求,存在各种Gremlin方言,包括Gremlin-Groovy、Gremlin-Scala和Gremlin-Clojure等。上面的Gremlin-Java8遍历最终被编译成称为遍历(traversal)的步骤序列。下面提供了遍历的字符串表示。

[GraphStep([],vertex)@[a], VertexStep(OUT,[knows],vertex)@[b], SelectStep([a, b],[value(name), value(age)])]

这些步骤(steps)是Gremlin图遍历机的原语。它们是机器最终执行的参数化指令。Gremlin指令集大约有30个步骤。这些步骤足以提供通用计算以及表达任何图遍历查询的共同主题通常所需的内容。 鉴于Gremlin是一种语言、一个指令集和一个虚拟机,可以设计另一种编译为Gremlin遍历机器的遍历语言(类似于Scala如何编译到JVM)。例如,可以编译流行的SPARQL图模式匹配语言以在Gremlin机器上执行。以下SPARQL查询

SELECT ?a ?b ?c
WHERE {
  ?a a Person .
  ?a ex:knows ?b .
  ?a ex:created ?c .
  ?b ex:created ?c .
  ?b ex:age ? d .
    FILTER(?d < 30)
}

将被编译到

[GraphStep([],vertex), MatchStep(AND,[[MatchStartStep(a), LabelStep, IsStep(eq(Person)), MatchEndStep], [MatchStartStep(a), VertexStep(OUT,[knows],vertex), MatchEndStep(b)], [MatchStartStep(a), VertexStep(OUT,[created],vertex), MatchEndStep(c)], [MatchStartStep(b), VertexStep(OUT,[created],vertex), MatchEndStep(c)], [MatchStartStep(b), PropertiesStep([age],value), MatchEndStep(d)], [MatchStartStep(d), IsStep(gt(30)), MatchEndStep]]), SelectStep([a, b, c])].

在Gremlin-Java8中,上面的SPARQL查询将被编译为相同的Gremlin步骤序列(即遍历),其表示如下。

g.V().match(
  as("a").label().is("person"),
  as("a").out("knows").as("b"),
  as("a").out("created").as("c"),
  as("b").out("created").as("c"),
  as("b").values("age").as("d"),
  as("d").is(gt(30))).
    select("a","b","c")

Gremlin机(虚拟机)

Gremlin图遍历机可以在单台机器上执行,也可以在多机计算集群上执行。执行不可知论允许Gremlin在图数据库(OLTP)和图处理器(OLAP)上运行。

参考文献

  1. ^ Release 2.6.0. 2014年9月17日 [2020年5月29日]. 
  2. ^ Rodriguez, Marko A. The Gremlin graph traversal machine and language (invited talk). 2015: 1–10. ISBN 9781450339025. arXiv:1508.03843 . doi:10.1145/2815072.2815073. 
  3. ^ The Benefits of the Gremlin Graph Traversal Machine. 2015-09-14 [2015-09-17]. (原始内容存档于2018-10-30). 
  4. ^ The Gremlin Graph Traversal Language. 2015-08-19 [2015-08-22]. (原始内容存档于2020-11-08). 

外部链接

  1. Apache TinkerPop主页页面存档备份,存于互联网档案馆
  2. GremlinDocs.com (TinkerPop2)
  3. sql2gremlin.com (TinkerPop2)
  4. Rodriguez, M.A., "The Gremlin Graph Traversal Machine and Language," Proceedings of the ACM Database Programming Languages Conference, October, 2015.