phoenix 与现有的HBase表关联
首先创建一张HBase表,再创建的Phoenix表,表名必须和HBase表名一致即可。
create 'stu' ,'cf1','cf2'
put 'stu', 'key1','cf1:name','luozhao'
put 'stu', 'key1','cf1:sex','man'
put 'stu', 'key1','cf2:age','24'
put 'stu', 'key1','cf2:adress','cqupt'
连接phoenix
phoenix-sqlline.py localhost:2181
创建与hbase一样的表
create table "stu"("ROW" varchar primary key,"cf1"."name" VARCHAR ,"cf1"."sex" VARCHAR ,"cf2"."age" VARCHAR ,"cf2"."adress" VARCHAR );
注意红色这个字段必须和hbase(如下图)里的相一致。ROW默认是hbase的关键字
增加数据
upsert into "stu"(ROW,"cf1"."name","cf1"."sex","cf2"."age","cf2"."adress") values('key6','zkk','man','111','Beijing');
查看数据是否同步
select * from "stu";
hbase 里查看数据,已经同步完毕,