https://github.com/forcedotcom/phoenix
http://www.vogella.com/articles/MySQLJava/article.html
HBase shell :
create 't1', {NAME => 'f1', VERSIONS => 5}
put 't1', "row1", 'f1:1', "aaa"
scan 't1'
Phoneix:
!tables
CREATE TABLE IF NOT EXISTS "t1" (
row VARCHAR NOT NULL,
"f1"."1" VARCHAR
CONSTRAINT PK PRIMARY KEY (row)
);
select * from "t1";
drop table "t1"; // t1表里面的数据被删除掉了,但是table是存在的。
./sqlline.sh node35:2224 ../examples/stock_symbol.sql
./psql.sh node35:2224 ../examples/web_stat.sql ../examples/web_stat.csv ../examples/web_stat_queries.sql
./performance.sh node35:2224 1000000
performance.sh里面
# Create Table DDL
createtable="CREATE TABLE IF NOT EXISTS $table (HOST CHAR(2) NOT NULL,DOMAIN VARCHAR NOT NULL,
FEATURE VARCHAR NOT NULL,DATE DATE NOT NULL,USAGE.CORE BIGINT,USAGE.DB BIGINT,STATS.ACTIVE_VISITOR
INTEGER CONSTRAINT PK PRIMARY KEY (HOST, DOMAIN, FEATURE, DATE))
SPLIT ON ('CSGoogle','CSSalesforce','EUApple','EUGoogle','EUSalesforce','NAApple','NAGoogle','NASalesforce');"
0: jdbc:phoenix:node35:2224> select count(*) from PERFORMANCE_1000000;
+----------+
| COUNT(1) |
+----------+
| 1000000 |
+----------+
0: jdbc:phoenix:node35:2224> select * from PERFORMANCE_1000000 limit 2;
+------+------------+------------+---------------------+----------+----------+----------------+
| HOST | DOMAIN | FEATURE | DATE | CORE | DB | ACTIVE_VISITOR |
+------+------------+------------+---------------------+----------+----------+----------------+
| CS | Apple.com | Dashboard | 2013-10-22 | 425 | 1906 | 4744 |
| CS | Apple.com | Dashboard | 2013-10-22 | 471 | 875 | 9533 |
+------+------------+------------+---------------------+----------+----------+----------------+
0: jdbc:phoenix:node35:2224> explain select count(*) from PERFORMANCE_1000000;
+------------+
| PLAN |
+------------+
| CLIENT PARALLEL 27-WAY FULL SCAN OVER PERFORMANCE_1000000 |
| SERVER AGGREGATE INTO SINGLE ROW |
+------------+
0: jdbc:phoenix:node35:2224> explain select * from PERFORMANCE_1000000 limit 2;
+------------+
| PLAN |
+------------+
| CLIENT PARALLEL 27-WAY FULL SCAN OVER PERFORMANCE_1000000 |
| SERVER FILTER BY PageFilter 2 |
| CLIENT 2 ROW LIMIT |
+------------+
import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; public class UsePhoenix { public static void main(String[] args) { try { // Register Class.forName("com.salesforce.phoenix.jdbc.PhoenixDriver"); // Address String DBConnectionString = "jdbc:phoenix:10.232.98.35:2224"; Connection connection = DriverManager.getConnection(DBConnectionString); Statement statement = connection.createStatement(); ResultSet rs = statement .executeQuery("select count( *) from PERFORMANCE_1000000"); rs.next(); System.out.println("Count " + rs.getLong(1)); connection.close(); } catch (Exception e) { e.printStackTrace(); } } }
./psql.sh node35:2224 count.sql
./sqlline.sh node35:2224 count.sql
http://www.slideshare.net/Hadoop_Summit/taylor-june27-230pmhall1v2?from_search=6
phoenix使用的元数据都放在一张hbase表(SYSTEM.TABLE )里面,建表的时候可以直接映射到已有的HBase表,这样子数据不需要迁移。
见 https://github.com/forcedotcom/phoenix/wiki
Mapping to an Existing HBase Table
如下操作先创建一张hbase表
create 't2', {NAME => 'f1', VERSIONS => 5}
put 't2', "row1", 'f1:q', "aaa"
put 't2', "row2", 'f1:q', "bbb"
put 't2', "row3", 'f1:q', "ccc"
在phoenix建一张同样的表
./sqlline.sh localhost
CREATE TABLE IF NOT EXISTS "t2" (
row VARCHAR NOT NULL,
"f1"."q" VARCHAR
CONSTRAINT PK PRIMARY KEY (row)
);
t2 f1 q需要用双引号括起来,原因主要是大小写的问题,参考phoenix的wiki https://github.com/forcedotcom/phoenix/wiki
注意在这里,phoenix会修改table的Descriptor,然后添加coprocessor,所以会先disable,在modify,最后enable表。
0: jdbc:phoenix:localhost> CREATE TABLE IF NOT EXISTS "t2" (
. . . . . . . . . . . . .> row VARCHAR NOT NULL,
. . . . . . . . . . . . .> "f1"."q" VARCHAR
. . . . . . . . . . . . .> CONSTRAINT PK PRIMARY KEY (row)
. . . . . . . . . . . . .> );
0: jdbc:phoenix:localhost> select * from "t2";
+------------+------------+
| ROW | q |
+------------+------------+
| row1 | aaa |
| row2 | bbb |
| row3 | ccc |
+------------+------------+
0: jdbc:phoenix:localhost> SELECT COUNT(1) FROM "t2";
+----------+
| COUNT(1) |
+----------+
| 3 |
+----------+
't2', {METHOD => 'table_att', coprocessor$1 => '|com.salesforce.phoenix.coprocessor.ScanRegionObserver|1|', coprocessor$2 => '|com.salesforce.phoenix.coprocessor.UngroupedAggregateRegionObserver|1|', coprocessor$3 => '|com.salesforce.phoenix.coprocessor.GroupedAggregateRegionObserver|1|', coprocessor$4 => '|com.salesforce.phoenix.join.HashJoiningRegionObserver|1|'}, {NAME => 'f1', VERSIONS => '5', KEEP_DELETED_CELLS => 'true'}
'SYSTEM.TABLE', {METHOD => 'table_att', coprocessor$1 => '|com.salesforce.phoenix.coprocessor.ScanRegionObserver|1|', coprocessor$2 => '|com.salesforce.phoenix.coprocessor.UngroupedAggregateRegionObserver|1|', coprocessor$3 => '|com.salesforce.phoenix.coprocessor.GroupedAggregateRegionObserver|1|', coprocessor$4 => '|com.salesforce.phoenix.join.HashJoiningRegionObserver|1|', coprocessor$5 => '|com.salesforce.phoenix.coprocessor.MetaDataEndpointImpl|1|', coprocessor$6 => '|com.salesforce.phoenix.coprocessor.MetaDataRegionObserver|2|', CONFIG => {'SPLIT_POLICY' => 'com.salesforce.phoenix.schema.MetaDataSplitPolicy', 'UpgradeTo20' => 'true'}}, {NAME => '_0', DATA_BLOCK_ENCODING => 'FAST_DIFF', VERSIONS => '1000', KEEP_DELETED_CELLS => 'true'}
相关推荐
Phoneix嵌入式软件包: PhoenixCard_V310_20130618.zip PhoenixSuit_CN_V1.0.6.zip PhoneixUSBPro_V_4_0_0__2014-09-12CN.zip
亲手在Centos7上安装,所用软件列表 apache-flume-1.8.0-bin.tar.gz apache-phoenix-4.13.0-HBase-1.3-bin.tar.gz hadoop-2.7.4.tar.gz hbase-1.3.1-bin.tar.gz jdk-8u144-linux-x64.tar.gz kafka_2.12-1.0.0.tgz ...
PHOENIX BIOS 4.0 启动自检代码 过路人 odv1@qq.com hi.baidu.com/odv1
创新点:使用Phoneix工具对非关系型数据库进行数据储存与查询 技术路线: 1、数据储存:Hbase 2、数据分析:Phoneix 3、数据管理:SpringBoot+MyBaties+JSP+Layui 4、数据可视化:SpringBoot+echart可视化
Phoenix BIOS Editor 2.0.18.0
Programming Phoenix Productive Reliable Fast 英文epub
cdh6.3.2 适配 Phoenix; cdh6.3.2 集成 Phoenix
Phoenix是一个HBase的开源SQL引擎。你可以使用标准的JDBC API代替HBase客户端API来创建表,插入数据,查询你的HBase数据。 Phoenix是构建在HBase之上的SQL引擎。你也许会存在“Phoenix是否会降低HBase的效率?...
Phoenix BIOS Editor Pro v2.2.1.3 By Tidosho 最新版本.国外大神破解.无广告.无弹窗.已注册.把dat复制到主程序安装目录下即可.
flink sql读写phoenix所使用到的连接器依赖包: flink-sql-connector-phoenix-1.14-1.0.jar 使用示例: create table tab2( ID STRING, NAME STRING, PRIMARY KEY (ID) NOT ENFORCED )WITH( ...
Phoenix安装使用手册Phoenix安装使用手册Phoenix安装使用手册Phoenix安装使用手册Phoenix安装使用手册
CLABS_PHOENIX-4.3.0-1.clabs_phoenix1.0.0.p0.78-el6.parcel.sha1 manifest.json 对应hbase版本1.0 分割成5份
CLABS_PHOENIX-4.3.0-1.clabs_phoenix1.0.0.p0.78-el6.parcel.sha1 manifest.json 对应hbase版本1.0 分割成5份
这是一款开源六足代码和自己画的六足机器人机械结构,希望能够一起学习。
DUnit Xtreme testing for Delphi居然Delphi盒子上没有一个单元测试工具,正好最近要用到Dunit,到Sourceforge上下载了最新的9.2.0版本,上传上来,免得登录外国的网站太慢!
仪表盘 要启动Phoenix服务器: 使用mix deps.get安装依赖mix deps.get 使用mix ecto.setup创建和迁移数据库 使用npm install在assets目录中安装Node.js依赖项 使用mix phx.server启动Phoenix端点 ...
Phoenix Crisis Recovery Disk_WINCRIS与ThinkPad X200 7458 提取BIOS
Phoenix bios 全机型 用来破解Phoenix bios密码再好不过了
Essential_C++答案,是英文版的
今天看看怎样在 python 中使用 phoenixdb 来操作 hbase 安装 phoenixdb 库 pip install phoenixdb 例子 首先启动 queryserver 服务 cd apache-phoenix-4.14.1-HBase-1.4-bin/bin ./queryserver.py ...