hbase的表与phoenix建立映射,hbasephoenix映射
一,hbase的表与phoenix建立映射
1, 具体步骤如下:
(1) 先在hbase上建立表,表名为(PHO)
hbase(main):001:0>create 'PHO','KID','INFO'
(2), 然后在phoenix上建立相同的表名 (PHO)
0: jdbc:phoenix:db1,db2,db3:2181>create table if not exists PHO(id varchar primary key,
info.create_date varchar,
info.user_id varchar,
info.username varchar,
info.password varchar,
)SALT_BUCKETS=32;
(3), hdfs上数据导入到hbase表上,其中/testdata/lch1/output1/为hdfs上存放输入数据源,/testdata/lch1/output1/为hdfs上的输出hfile
hbase org.apache.hadoop.hbase.mapreduce.ImportTsv -Dimporttsv.columns=HBASE_ROW_KEY,INFO:CREATE_DATE,INFO:USER_ID,INFO:USERNAME,INFO:PASSWORD -Dimporttsv.bulk.output=/testdata/lch1/output1/ PHO /testdata/lch1/inputdata1
hbase org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles /testdata/lch1/output1/ PHO
(4),数据导入成功后,即可以通过phoenix上查询该表数据
0: jdbc:phoenix:db1,db2,db3:2181>select * from PHO;
本站文章为和通数据库网友分享或者投稿,欢迎任何形式的转载,但请务必注明出处.
同时文章内容如有侵犯了您的权益,请联系QQ:970679559,我们会在尽快处理。