原文链接 : http://zeppelin.apache.org/docs/0.7.2/interpreter/geode.html
译文链接 : http://cwiki.apachecn.org/pages/viewpage.action?pageId=10030798
概述
名称 | 类 | 描述 |
---|---|---|
%geode.oql | GeodeOqlInterpreter | 为Apache Geode提供OQL环境 |
此解释器支持Geode 对象查询语言(OQL)。使用基于OQL的查询语言:
- 您可以查询任何任意对象
- 您可以浏览对象集合
- 您可以调用方法并访问对象的行为
- 支持数据映射
- 您不需要声明类型。由于您不需要类型定义,您可以跨多种语言工作
- 您不受模式约束
本视频教程说明了该功能提供的一些功能Geode Interpreter
。
创建解释器
默认情况下,Zeppelin创建一个Geode/OQL
实例。您可以删除它或创建更多的实例。
可以创建多个Geode实例,每个实例都配置为相同或不同的后端Geode集群。但是随着时间的推移, Notebook
可以只有一个Geode解释器实例bound
。这意味着您无法连接到同一个不同的Geode集群Notebook
。这是一个已知的Zeppelin限制。
要创建新的Geode实例,请打开该Interpreter
部分,然后单击该+Create
按钮。选择Name
您的选择,并从Interpreter
下拉列表中选择geode
。然后按照配置说明和Save
新实例进行操作。
注意:该
Name
实例仅用于区分实例,同时绑定它们Notebook
。这Name
是不相干的Notebook
。在Notebook
你必须使用%geode.oql
标签。
绑定到笔记本
在Notebook
上点击settings
在右上角的图标。选择/取消选择要与之绑定的口译员Notebook
。
配置
您可以从Interpreter
部分修改Geode的配置。Geode解释器表示以下属性:
属性名称 | 描述 | 默认值 |
---|---|---|
geode.locator.host | Geode定位器主机 | 本地主机 |
geode.locator.port | Geode定位器端口 | 10334 |
geode.max.result | 显示OQL结果的最大数量,以防止浏览器过载 | 1000 |
如何使用
提示1:使用(CTRL +。)进行OQL自动完成。
提示2:始终使用完整的
%geode.oql
前缀标签启动段落!简短的符号:%geode
仍然可以运行OQL查询,但语法突出显示和自动完成将被禁用。
创建/销毁区域
OQL规范不支持 Geode Regions突变操作。对create
/ destroy
区域应该使用GFSH shell工具。在下文中,假设GFSH与Zeppelin服务器共同配置。
- %sh
- source /etc/geode/conf/geode-env.sh
- gfsh << EOF
- connect --locator=ambari.localdomain[10334]
- destroy region --name=/regionEmployee
- destroy region --name=/regionCompany
- create region --name=regionEmployee --type=REPLICATE
- create region --name=regionCompany --type=REPLICATE
- exit;
- EOF
以上片段重新创建了两个区域:regionEmployee
和regionCompany
。请注意,您必须明确指定定位器主机和端口。这些值应与Geode Interpreter配置中使用的值相匹配。功能区GFSH命令综合清单。
基本OQL
- %geode.oql
- SELECT count(*) FROM /regionEmployee
OQL IN
和SET
过滤器
- %geode.oql
- SELECT * FROM /regionEmployee
- WHERE companyId IN SET(2) OR lastName IN SET('Tzolov13', 'Tzolov73')
OQL JOIN
操作
- %geode.oql
- SELECT e.employeeId, e.firstName, e.lastName, c.id as companyId, c.companyName, c.address
- FROM /regionEmployee e, /regionCompany c
- WHERE e.companyId = c.id
默认情况下,QOL响应仅包含区域条目值。要访问密钥,请查询EntrySet
:
- %geode.oql
- SELECT e.key, e.value.companyId, e.value.email
- FROM /regionEmployee.entrySet e
以下查询将返回EntrySet值作为Blob:
- %geode.oql
- SELECT e.key, e.value FROM /regionEmployee.entrySet e
Shell的GFSH命令
使用Shell 解释器(%sh
)从命令行运行OQL命令:
- %sh
- source /etc/geode/conf/geode-env.sh
- gfsh -e "connect" -e "list members"
应用Zeppelin动态表单
您可以在OQL查询内使用Zeppelin 动态表单。您可以同时使用text input
和select form
参数化功能
- %geode.oql
- SELECT * FROM /regionEmployee e WHERE e.employeeId > ${Id}
自动完成
Geode解释器提供基本的自动完成功能。在(Ctrl+.)
其中列出最相关的建议在弹出窗口。
Geode REST API
要列出定义的区域,您可以使用Geode REST API:
- http://<geode server hostname>phd1.localdomain:8484/gemfire-api/v1/
- {
- "regions" : [{
- "name" : "regionEmployee",
- "type" : "REPLICATE",
- "key-constraint" : null,
- "value-constraint" : null
- }, {
- "name" : "regionCompany",
- "type" : "REPLICATE",
- "key-constraint" : null,
- "value-constraint" : null
- }]
- }
要使用JSON支持Geode REST API,请将以下属性添加到geode.server.properties.file并重新启动:
- http-service-port=8484
- start-dev-rest-api=true