演示示例 · Hadoop2.x

**演示一：手動進行minor compation合并** （1）創建emp_tb表 ```sql hbase(main):002:0> create 'emp_tb', NAME=>'addr' ``` （2）插入/更新數據 ```sql -- 插入數據 hbase(main):004:0> put 'emp_tb', 'r001', 'addr:city', 'beijing_001' -- 每次flush都是觸發一次Minor Compaction 操作 hbase(main):006:0> flush 'emp_tb' -- 第1次更新數據 hbase(main):004:0> put 'emp_tb', 'r001', 'addr:city', 'beijing_002' hbase(main):006:0> flush 'emp_tb' ``` hdfs上查看已經有了兩個版本的數據 hbase35 （3）合并兩個HFile文件 ```sql hbase(main):013:0> compact 'emp_tb' ``` 在hdfs上查看依然是沒有合并，因為HFile還沒有達到Minor Compation的數量要求，默認至少要達到3個。 ![](https://img.kancloud.cn/26/31/2631bee993e963fb3283127b5bc02266_1482x235.png) （4）第2次更新數據 ```sql hbase(main):004:0> put 'emp_tb', 'r001', 'addr:city', 'beijing_003' hbase(main):006:0> flush 'emp_tb' ``` 在hdfs上查看已達到3個HFile文件數量。 ![](https://img.kancloud.cn/2c/59/2c59966c06667d9697413fcab07d9bd3_1479x278.png) （5）合并三個HFile文件 ```sql hbase(main):023:0> compact 'emp_tb' ``` 在hdfs上查看3個HFile文件合并為一個了。 ![](https://img.kancloud.cn/6a/84/6a84b3fef4ba6f8975b20a55f0abc5bd_1477x223.png) <br/> **演示二：進行minor compation合并不刪除數據，只是添加墓碑標記；在major compation時數據才會被刪除** （1）清空emp_tb表 ```sql hbase(main):050:0> truncate 'emp_tb' ``` （2）插入數據 ```sql -- 設置可以保存10個最新版本的數據 alter 'emp_tb', NAME=>'addr', VERSIONS=>10 -- 插入數據 hbase(main):004:0> put 'emp_tb', 'r001', 'addr:city', 'beijing_001' ``` （3）做5次數據更新 ```sql hbase(main):024:0> put 'emp_tb', 'r001', 'addr:city', 'beijing_002' hbase(main):025:0> put 'emp_tb', 'r001', 'addr:city', 'beijing_003' hbase(main):026:0> put 'emp_tb', 'r001', 'addr:city', 'beijing_004' hbase(main):027:0> put 'emp_tb', 'r001', 'addr:city', 'beijing_005' hbase(main):028:0> put 'emp_tb', 'r001', 'addr:city', 'beijing_006' -- 每次flush都是觸發一次Minor Compaction 操作 hbase(main):006:0> flush 'emp_tb' ``` （4）查看 ```sql -- 查看當前最新版本的數據 hbase(main):087:0> scan 'emp_tb' ROW COLUMN+CELL r001 column=addr:city, timestamp=1608643095602, value=beijing_006 -- 查看最新的10個版本的數據 hbase(main):088:0> scan 'emp_tb', {RAW=>TRUE, VERSIONS=>10} ROW COLUMN+CELL r001 column=addr:city, timestamp=1608643095602, value=beijing_006 r001 column=addr:city, timestamp=1608643085718, value=beijing_005 r001 column=addr:city, timestamp=1608643070623, value=beijing_004 r001 column=addr:city, timestamp=1608643063183, value=beijing_003 r001 column=addr:city, timestamp=1608643053918, value=beijing_002 r001 column=addr:city, timestamp=1608643022925, value=beijing_001 ``` （5）第1次刪除 ```sql -- 刪除 hbase(main):089:0> delete 'emp_tb', 'r001', 'addr:city' -- 每次flush都是觸發一次Minor Compaction 操作 hbase(main):006:0> flush 'emp_tb' ``` 在hdfs查看，delete，然后flush后多出了一個HFile文件 ![](https://img.kancloud.cn/7f/6b/7f6b89b3c9df6a18cb153e62cf6887dc_1469x248.png) ``` -- 查看當前最新版本的數據，可以看到最新版本由原來006變為005 hbase(main):090:0> scan 'emp_tb' ROW COLUMN+CELL r001 column=addr:city, timestamp=1608643085718, value=beijing_005 -- 查看最新的10個版本的數據，可以看到006上面有一個Delete標記 -- 只是做了一個標記并沒有實際刪除 hbase(main):091:0> scan 'emp_tb', {RAW=>TRUE, VERSIONS=>10} ROW COLUMN+CELL r001 column=addr:city, timestamp=1608643095602, type=Delete r001 column=addr:city, timestamp=1608643095602, value=beijing_006 r001 column=addr:city, timestamp=1608643085718, value=beijing_005 r001 column=addr:city, timestamp=1608643070623, value=beijing_004 r001 column=addr:city, timestamp=1608643063183, value=beijing_003 r001 column=addr:city, timestamp=1608643053918, value=beijing_002 r001 column=addr:city, timestamp=1608643022925, value=beijing_001 ``` （6）第2次刪除 ```sql -- 刪除 hbase(main):094:0> delete 'emp_tb', 'r001', 'addr:city' -- 每次flush都是觸發一次Minor Compaction 操作 hbase(main):095:0> flush 'emp_tb' -- 查看當前最新版本的數據，可以看到最新版本由原來005變為004 hbase(main):096:0> scan 'emp_tb' ROW COLUMN+CELL r001 column=addr:city, timestamp=1608643070623, value=beijing_004 -- 查看最新的10個版本的數據，可以看到006和005上面有一個Delete標記 -- 只是做了一個標記并沒有實際刪除 hbase(main):097:0> scan 'emp_tb', {RAW=>TRUE, VERSIONS=>10} ROW COLUMN+CELL r001 column=addr:city, timestamp=1608643095602, type=Delete r001 column=addr:city, timestamp=1608643095602, value=beijing_006 r001 column=addr:city, timestamp=1608643085718, type=Delete r001 column=addr:city, timestamp=1608643085718, value=beijing_005 r001 column=addr:city, timestamp=1608643070623, value=beijing_004 r001 column=addr:city, timestamp=1608643063183, value=beijing_003 r001 column=addr:city, timestamp=1608643053918, value=beijing_002 r001 column=addr:city, timestamp=1608643022925, value=beijing_001 ``` 在hdfs查看有3個HFile文件了 ![](https://img.kancloud.cn/b9/df/b9dfde804adda82ac2d105a8586ee19a_1500x285.png) （7）進行Major Compaction ```sql hbase(main):098:0> major_compact 'emp_tb' -- 查看最新的10個版本的數據，可以看到006和005已經被刪除了 hbase(main):099:0> scan 'emp_tb', {RAW=>TRUE, VERSIONS=>10} ROW COLUMN+CELL r001 column=addr:city, timestamp=1608643070623, value=beijing_004 r001 column=addr:city, timestamp=1608643063183, value=beijing_003 r001 column=addr:city, timestamp=1608643053918, value=beijing_002 r001 column=addr:city, timestamp=1608643022925, value=beijing_001 ``` 在hdfs查看3個HFile文件合并成了一個 ![](https://img.kancloud.cn/4e/c2/4ec2a6a4a647d02d42b4439994f56cf9_1494x197.png)