HBase客户端API操作

命令行(hbase shell)

hbase shell进入客 户端

[hadoop@pg1 ~]$ hbase shell
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/ups/app/hbase/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/ups/app/hadoop/share/hadoop/common/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
HBase Shell; enter 'help<RETURN>' for list of supported commands.
Type "exit<RETURN>" to leave the HBase Shell
Version 1.3.6, r806dc3625c96fe2cfc03048f3c54a0b38bc9e984, Tue Oct 15 01:55:41 PDT 2019

hbase(main):001:0>

exit 退出 hbase shell 客户端

表结构操作

• create：创建
• list：查看表列表
• desc：查看表的详细信息
• drop：删除表
• truncate：清空表
• alter：修改表的定义

create

 help 'create'
 
 # t1是表名，f1,f2,f3是列簇的名
 create 't1', {NAME => 'f1'}, {NAME => 'f2'}, {NAME => 'f3'}
 
 # 创建了一个名为myHbase的表，表里面有1个列簇，名为myCard，保留5个版本信息
 create 'myHbase',{NAME => 'myCard',VERSIONS => 5}

list

hbase(main):046:0> list
TABLE                                    
myHbase                                                                             t1                                                                                                                               
2 row(s) in 0.0450 seconds

=> ["myHbase", "t1"]
hbase(main):047:0>

desc

hbase(main):047:0> desc 'myHbase'
Table myHbase is ENABLED
myHbase                 
COLUMN FAMILIES DESCRIPTION                                                                                                      
{NAME => 'myCard', BLOOMFILTER => 'ROW', VERSIONS => '5', IN_MEMORY => 'false', KEEP_DELETED_CELLS => 'FALSE', DATA_BLOCK_ENCODIN
G => 'NONE', TTL => 'FOREVER', COMPRESSION => 'NONE', MIN_VERSIONS => '0', BLOCKCACHE => 'true', BLOCKSIZE => '65536', REPLICATIO
N_SCOPE => '0'}         
1 row(s) in 0.0740 seconds

hbase(main):048:0>

修改表定义

添加一个列簇

alter 'myHbase', NAME => 'myInfo'

删除一个列簇

 alter 'myHbase', NAME => 'myCard', METHOD => 'delete'
 
 alter 'myHbase', 'delete' => 'myCard'

添加列簇hi同时删除列簇myInfo

alter 'myHbase', {NAME => 'hi'}, {NAME => 'myInfo', METHOD => 'delete'}

truncate

truncate 'myHbase'

drop

先停用表，再删除

disable 'myHbase'
drop 'myHbase'

表数据操作

• 增：put
• 删：delete
• 查：get + scan
• 改：==

创建 user 表，包含 info、data 两个列簇

create 'user_info',{NAME=>'base_info',VERSIONS=>3 },{NAME=>'extra_info',VERSIONS=>1 } 

增

需要传入表名，rowkey，列簇名、值等

向 user 表中插入信息，row key 为 user0001，列簇 base_info 中添加 name 列标示符，值为 zhangsan1

put 'user_info', 'user0001', 'base_info:name', 'zhangsan1'
put 'user_info', 'zhangsan_20150701_0001', 'base_info:name', 'zhangsan1'
put 'user_info', 'zhangsan_20150701_0002', 'base_info:name', 'zhangsan2'

put 'user_info', 'zhangsan_20150701_0001', 'base_info:age', '21'
put 'user_info', 'zhangsan_20150701_0002', 'base_info:age', '22'

put 'user_info', 'zhangsan_20150701_0001', 'extra_info:Hobbies', 'music'
put 'user_info', 'zhangsan_20150701_0002', 'extra_info:Hobbies', 'sport'

查(get + scan)

# 获取 user_info 表中 row key 为 user0001 的所有信息
get 'user_info', 'user0001'

# 获取user表中row key为user0001，base_info列簇的所有信息
get 'user_info', 'user0001', 'base_info'

# 查询user_info表中的所有信息
scan 'user_info'

# 查询user_info表中列簇为base_info的信息
scan 'user_info', {COLUMNS => 'base_info'}

删

# 删除user_info表row key为zhangsan_20150701_0001，列标示符为base_info:name的数据
delete 'user_info', 'zhangsan_20150701_0001', 'base_info:name'

scan 'user_info', {COLUMNS => 'base_info'}

使用过滤器

# 从mytable表中找到row1开头的所有row，那么就需要用到PrefixFilter
scan 'user_info', { FILTER => "(PrefixFilter ('zhangsan'))"}

# 使用KeyOnlyFilter
scan 'user_info', { FILTER => "(KeyOnlyFilter ())"}

# 使用 FirstKeyOnlyFilter()
scan 'user_info', { FILTER => "FirstKeyOnlyFilter ()"}

# 使用 MultipleColumnPrefixFilter()
scan 'user_info', { FILTER => "MultipleColumnPrefixFilter('age','name')"}

# 使用 ColumnCountGetFilter()
scan 'user_info', { FILTER => "ColumnCountGetFilter(2)"}

客户端API工具