表操作
创建表
更新表
alter “order_info”,”c2”
alter “order_info”,”delete”=>”c2”
查询表
删除表
disable “order_info”
drop “order_info”
数据操作
插入数据
put “order_info”,”0000001”,”c1:STATUS”,”已提交”
put “order_info”,”0000001”,”c1:PAY_MONRY”,4070
put “order_info”,”0000001”,”c1:PAYWAY”,1
put “order_info”,”0000001”,”c1:USER_ID”,4091000
put “order_info”,”0000001”,”c1:CREATE_TIME”,”2020-04-25 12:10:14”
put “order_info”,”0000001”,”c1:CATEGORY”,”手机”
查询数据
查询数据(查看中文)
get “order_info”,”0000001” ,{FORMATTER=>”toString”}
扫描数据
scan “order_info” ,{FORMATTER=>”toString”}
scan “order_info” ,{LIMIT=>2,FORMATTER=>”toString”}
scan “order_info” ,{ROWPREFIXFILTER=>’0000001’,LIMIT=>2,FORMATTER=>”toString”}
更新数据
put “order_info”,”0000001”,”c1:STATUS”,”已付款”
删除数据
deleteall “order_info”,”0000001”
删除列簇
delete “order_info”,”0000001”,”c1:CATEGORY”
数据统计
数据统计(大量)
hbase org.apache.hadoop.hbase.mapreduce.RowCounter “order_info”
前置条件:(启动Yarn集群)
start-yarn.sh
mr-jobhistory-daemon.sh start historyserver
过滤器(scan+filter)
过滤器参考:
https://hbase.apache.org/devapidocs/index.html
scan “order_info” ,{FILTER=>”RowFilter(=,’binary:0000001’)”,FORMATTER=>”toString”}
scan “order_info” ,{FILTER=>”SingleColumnValueFilter(‘c1’,’PAYWAY’,=,’binary:1’) AND SingleColumnValueFilter(‘c1’,’PAY_MONEY’,<,’binary:5070’)”,FORMATTER=>”toString”}
INCR(HBase计数器)
create ‘new_visit’,’c1’
incr ‘new_visit’,’00000000001_00:00-12:00’,’c1:CNT’,12
incr ‘new_visit’,’00000000002_12:00-18:00’,’c1:CNT’,6
incr ‘new_visit’,’00000000001_18:00-24:00’,’c1:CNT’,7
get_counter ‘new_visit’,’00000000001_18:00-24:00’,’c1:CNT’
incr ‘new_visit’,’00000000001_18:00-24:00’,’c1:CNT’
管理命令
- status
- whoami
- exists
- drop
- list
- truncate