弹性 MapReduce Phoenix 客户端使用

Phoenix 查询引擎支持使用 SQL 进行 HBase 数据的查询,会将 SQL 查询转换为一个或多个 HBase API,协同处理器与自定义过滤器的实现,并编排执行。使用 Phoenix 进行简单查询,其性能量级是毫秒,对于百万级别的行数来说,其性能量级是秒。EMR 中选择 HBase 组件的集群,默认集成 phoenix 客户端。

相关产品
弹性 MapReduce 产品页,含版本规格、价格与购买入口。

1. 启动客户端
切换成 hadoop 用户,进入/usr/local/service/hbase/phoenix-client/bin 目录,使用 Phoenix 的 Python 命令行工具:

./sqlline.py

执行成功后显示:

2. Phoenix 引擎支持使用 SQL 进行数据查询,一些常见操作如下:

·创建表

0: jdbc:phoenix:> CREATE TABLE IF NOT EXISTS TEST ( host char(50) not null, txn_count bigint CONSTRAINT pk PRIMARY KEY (host));

·插入数据

0: jdbc:phoenix:>UPSERT INTO TEST(host,txn_count) VALUES('192.168.1.1',1);0: jdbc:phoenix:>UPSERT INTO TEST(host,txn_count) VALUES('192.168.1.2',2);

·查询数据

0: jdbc:phoenix:>SELECT * FROM TEST;

·删除数据表

0: jdbc:phoenix:>DROP TABLE IF EXISTS TEST;

更多操作及说明,可参考 社区文档。

赞 (0)
上一篇 4天前
下一篇 4天前