Skip to content

Geode/Gemfire OQL 解释器

原文链接 : http://zeppelin.apache.org/docs/0.7.2/interpreter/geode.html

译文链接 : https://www.apachecn.org/pages/viewpage.action?pageId=10030798

贡献者 : 片刻 ApacheCN Apache中文网

概述

名称 类 描述
％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 

注意：您可以在同一段落中有多个查询，但只显示第一个查询结果。[ 1 ]，[ 2 ]。

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 
回到顶部