Hbase和phoenix结合应用
任务
将 csv文件导入到hbase中;
用hbase shell查询表的内容;
用phoenix在hbase上完成关系型数据库查询语句对表的查询
解决步骤
①将csv文件导入到hdfs中
hadoop fs -put hbasePut.csv /
②在Hbase中创建表hbase_csv
create ‘hbase_csv’ , ’info’ 所有列都放在列族info中
③通过命令
hbase org.apache.hadoop.hbase.mapreduce.importTsv -Dimporttsv.separator="," -Dimporttsv.columns='Hbase_ROW_KEY,info:sno,info:sname,info:plt,info:alb,info:age40_60,info:ca,info:age<40,info:smo_his,info:le_woed,info:cap,info:age61_74,info:age>74,info:score' hbase_csv /hbasePut.csv 将hdfs中的/hbasePut.csv导入到Hbase的hbase_csv中
④查看
scan ‘hbase_csv’
⑤用phoenix查询hbase中的hbase_csv
先下载在安装好对应hbase版本的phoenix,并配置,
在phoenix的bin目录输入 ./sqlline.py hadoop1,hadoop2,hadoop3:2181
创建hbase_csv的视图
注意表名、列名、列族名都带上双引号,否则phoenix会全部转为大写进行识别,同样的在执行phoenix的查询命令时要给字符串用单引号,因为双引号里的会被识别为列或表或列族。
可以用!tables查看一下当前phoenix里的表和视图。
发现hbase_csv视图已经存在
然后可以进行查询,查询语句和sql类似



