表操作

创建表

create “order_info”,”c1”

更新表

alter “order_info”,”c2”
alter “order_info”,”delete”=>”c2”

查询表

list

删除表

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”

查询数据(查看中文)

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”

数据统计

count “order_info”

数据统计(大量)

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