HBase 练习

查看HBase版本
1
2
hbase(main):033:0> version
1.4.13, r38bf65a22b7e9320f07aeb27677e4533b9a77ef4, Sun Feb 23 02:06:36 PST 2020
集群状态
1
2
hbase(main):034:0> status
1 active master, 0 backup masters, 1 servers, 0 dead, 4.0000 average load
创建Teacher表，包含一个列族Info
1
2
hbase(main):041:0> create 'Teacher','Info'
0 row(s) in 2.3430 seconds
创建Student表，两个列族Info和Score；列族Info的数据在读取时关闭缓存BLOCKCACHE。列族Score内的数据保留2个版本VERSIONS
1
2
hbase(main):047:0> create 'Student',{NAME=>'Info',BLOCKCACHE=>'false'},{NAME=>'Score',VERSIONS=>2}
0 row(s) in 2.3500 seconds
查看Student表结构
1
2
3
4
5
6
7
8
9
hbase(main):048:0> desc 'Student'
Table Student is ENABLED                                                                                                                                                 
Student                                                                                                                                                                  
COLUMN FAMILIES DESCRIPTION                                                                                                                                              
{NAME => 'Info', BLOOMFILTER => 'ROW', VERSIONS => '1', IN_MEMORY => 'false', KEEP_DELETED_CELLS => 'FALSE', DATA_BLOCK_ENCODING => 'NONE', TTL => 'FOREVER', COMPRESSION
 => 'NONE', MIN_VERSIONS => '0', BLOCKCACHE => 'false', BLOCKSIZE => '65536', REPLICATION_SCOPE => '0'}                                                                  
{NAME => 'Score', BLOOMFILTER => 'ROW', VERSIONS => '2', IN_MEMORY => 'false', KEEP_DELETED_CELLS => 'FALSE', DATA_BLOCK_ENCODING => 'NONE', TTL => 'FOREVER', COMPRESSIO
N => 'NONE', MIN_VERSIONS => '0', BLOCKCACHE => 'true', BLOCKSIZE => '65536', REPLICATION_SCOPE => '0'}                                                                  
2 row(s) in 0.0260 seconds
查看HBase中已有的表
1
2
3
4
5
6
hbase(main):049:0> list
TABLE                                                                     
Student                                                         
Teacher                                                
2 row(s) in 0.0240 seconds
=> ["Student", "Teacher"]
禁用表Teacher
1
hbase(main):050:0> disable 'Teacher'
判断表Teacher是否被禁用
1
2
hbase(main):051:0> is_disabled 'Teacher'
true
删除表Teacher
1
hbase(main):052:0> drop 'Teacher'
判断表Teacher是否还存在
1
2
hbase(main):053:0> exists 'Teacher'
Table Teacher does not exist
修改Student表，列族 Score 内的数据保留3个版本

查看表结构，验证是否修改成功。

1
2
3
4
hbase(main):054:0> alter 'Student',{NAME=>'Score',VERSIONS=>3}
Updating all regions with the new schema...
1/1 regions updated.
Done.
修改Student表，增加一个列族hobby

查看表结构，验证是否修改成功。

1
2
3
4
hbase(main):055:0> alter 'Student','hoby'
Updating all regions with the new schema...
0/1 regions updated.
1/1 regions updated.
修改Student表，删除列族hobby

查看表结构，验证是否修改成功。

1
2
3
4
hbase(main):057:0> alter 'Student',{NAME=>'hobby',METHOD=>'delete'}
Updating all regions with the new schema...
1/1 regions updated.
Done.
期末考试

将以下同学的期末考试成绩存入Student表，然后查询全表。

No Info Score
name age Hadoop HBase Spark
001 qiaofeng 30 93 85 70
002 duanyu 27 95 98 50
003 wangyuyan 18 95 97 92 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
put 'Student','001','Info:name','qiaofeng'
put 'Student','001','Info:age','30'
put 'Student','001','Score:Hadoop','93'
put 'Student','001','Score:Hbase','85'
put 'Student','001','Score:Spark','70'

put 'Student','002','Info:name','duanyu'
put 'Student','002','Info:age','27'
put 'Student','002','Score:Hadoop','95'
put 'Student','002','Score:Hbase','98'
put 'Student','002','Score:Spark','50'

put 'Student','003','Info:name','wangyuyan'
put 'Student','003','Info:age','18'
put 'Student','003','Score:Hadoop','95'
put 'Student','003','Score:Hbase','97'
put 'Student','003','Score:Spark','92'
1
hbase(main):077:0> scan 'Student'
补考

段誉补考了一次Spark，老师给登记了55分。

1
hbase(main):080:0> put 'Student','002','Score:Spark','55'

段誉登录学校教务系统，查询一下个人信息和成绩

1
2
3
4
5
6
7
8
hbase(main):083:0> get 'Student','002'
COLUMN                                      CELL
 Info:age                                   timestamp=1648555981987, value=27
 Info:name                                  timestamp=1648555873577, value=duanyu
 Score:Hadoop                               timestamp=1648556200639, value=95 
 Score:Hbase                                timestamp=1648556226943, value=98  
 Score:Spark                                timestamp=1648556643468, value=55  
1 row(s) in 0.0170 seconds

后来段誉动了歪脑筋，托关系走后门，获得了一次补考机会。结果事与愿违，老师登记补考成绩56分。

1
hbase(main):082:0> put 'Student','002','Score:Spark','56'

段誉又去查询了一下个人成绩

1
2
3
4
5
6
hbase(main):084:0> get 'Student','002','Score'
COLUMN                                      CELL                   
 Score:Hadoop                               timestamp=1648556200639, value=95      
 Score:Hbase                                timestamp=1648556226943, value=98
 Score:Spark                                timestamp=1648556808780, value=56
1 row(s) in 0.0180 seconds

没错，又挂了。

重修

经过两次补考，认真重修了Spark，最终老师批阅试卷，登记了98分

1
hbase(main):085:0> put 'Student','002','Score:Spark','98'

段誉登录教务系统查询了一下自己Spark单科成绩。

1
2
3
4
hbase(main):087:0> get 'Student','002','Score:Spark'
COLUMN                                      CELL                 
 Score:Spark                                timestamp=1648557259939, value=98
1 row(s) in 0.0070 seconds

后来他回顾了一下Spark历史成绩

1
2
3
4
5
6
hbase(main):086:0> get 'Student','002',{COLUMN=>'Score:Spark',VERSIONS=>3}
COLUMN                                      CELL    
 Score:Spark                                timestamp=1648557259939, value=98   
 Score:Spark                                timestamp=1648556808780, value=56    
 Score:Spark                                timestamp=1648556643468, value=55
1 row(s) in 0.0100 seconds
教务老师

查询所有同学的个人信息(Info)

1
2
3
4
5
6
7
8
9
hbase(main):004:0> scan 'Student',{COLUMN=>'Info'}
ROW                 COLUMN+CELL                        
 001                column=Info:age, timestamp=1648555932178, value=30
 001                column=Info:name, timestamp=1648555865078, value=qiaofeng
 002                column=Info:age, timestamp=1648555981987, value=27 
 002                column=Info:name, timestamp=1648555873577, value=duanyu 
 003                column=Info:age, timestamp=1648555988871, value=18
 003                column=Info:name, timestamp=1648555884874, value=wangyuyan   
3 row(s) in 0.0910 seconds

查看所有同学的Hadoop成绩(Scoe:Hadoop)

1
2
3
4
5
6
hbase(main):005:0> scan 'Student',{COLUMN=>'Score:Hadoop'}
ROW                  COLUMN+CELL
 001                 column=Score:Hadoop, timestamp=1648556188482, value=93
 002                 column=Score:Hadoop, timestamp=1648556200639, value=95
 003                 column=Score:Hadoop, timestamp=1648556207324, value=95
3 row(s) in 0.0190 seconds

查询所有同学的姓名(Info:name)和各科成绩(Score)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
hbase(main):006:0> scan 'Student',{COLUMNS=>['Info:name','Score']}
ROW                COLUMN+CELL                                          
 001               column=Info:name, timestamp=1648555865078, value=qiaofeng
 001               column=Score:Hadoop, timestamp=1648556188482, value=93
 001               column=Score:Hbase, timestamp=1648556219092, value=85
 001               column=Score:Spark, timestamp=1648556262488, value=70
 002               column=Info:name, timestamp=1648555873577, value=duanyu
 002               column=Score:Hadoop, timestamp=1648556200639, value=95
 002               column=Score:Hbase, timestamp=1648556226943, value=98
 002               column=Score:Spark, timestamp=1648557259939, value=98
 003               column=Info:name, timestamp=1648555884874, value=wangyuyan
 003               column=Score:Hadoop, timestamp=1648556207324, value=95
 003               column=Score:Hbase, timestamp=1648556249759, value=97
 003               column=Score:Spark, timestamp=1648556278852, value=92
3 row(s) in 0.0750 seconds

查询前两名同学的姓名(Info:name)和各科成绩(Score)

1
2
3
4
5
6
7
8
9
10
11
hbase> scan 'Student',{COLUMNS=>['Info:name','Score'],STARTROW=>'001',ENDROW=>'003'}
ROW                   COLUMN+CELL                                    
 001                  column=Info:name, timestamp=1648555865078, value=qiaofeng
 001                  column=Score:Hadoop, timestamp=1648556188482, value=93
 001                  column=Score:Hbase, timestamp=1648556219092, value=85
 001                  column=Score:Spark, timestamp=1648556262488, value=70
 002                  column=Info:name, timestamp=1648555873577, value=duanyu
 002                  column=Score:Hadoop, timestamp=1648556200639, value=95
 002                  column=Score:Hbase, timestamp=1648556226943, value=98 
 002                  column=Score:Spark, timestamp=1648557259939, value=98
2 row(s) in 0.0670 seconds
删除

删除乔峰的Hadoop成绩，查询一下是否删除成功。

1
2
3
4
5
6
7
8
hbase(main):009:0> delete 'Student','001','Score:Hadoop'
0 row(s) in 0.1620 seconds

hbase(main):010:0> get 'Student','001','Score'
COLUMN                                      CELL   
 Score:Hbase                                timestamp=1648556219092, value=85 
 Score:Spark                                timestamp=1648556262488, value=70
1 row(s) in 0.1310 seconds

查询段誉三次Spark成绩，删除段誉第一次补考成绩，再次查询段誉的三次成绩。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
# 查询三次历史成绩
hbase(main):011:0> get 'Student','002',{COLUMN=>'Score:Spark',VERSIONS=>3}
COLUMN                                      CELL         
 Score:Spark                                timestamp=1648557259939, value=98
 Score:Spark                                timestamp=1648556808780, value=56
 Score:Spark                                timestamp=1648556643468, value=55
1 row(s) in 0.0240 seconds

# 删除第一次补考成绩
hbase(main):012:0> delete 'Student','002','Score:Spark',1648556643468
0 row(s) in 0.0310 seconds

# 再次查询三次历史成绩
hbase(main):013:0> get 'Student','002',{COLUMN=>'Score:Spark',VERSIONS=>3}
COLUMN                                      CELL                              
 Score:Spark                                timestamp=1648557259939, value=98
 Score:Spark                                timestamp=1648556808780, value=56 
 Score:Spark                                timestamp=1648556271299, value=50 
1 row(s) in 0.0150 seconds
删除王语嫣整条记录
1
hbase(main):014:0> deleteall 'Student','003'
退出 - exit
1
hbase(main):014:0> exit