1. 程式人生 > >HBase shell 命令建立表及新增資料操作

HBase shell 命令建立表及新增資料操作

建立表,表名hbase_1102,HBase表是由Key-Value組成的,此表中Key為NAME 
 


此表有兩個列族,CF1和CF2,其中CF1和CF2下分別有兩個列name和gender,Chinese和Math 
1,建立表hbase_1102有兩個列族CF1和CF2

hbase(main):041:0> create 'hbase_1102',  {NAME=>'cf1'}, {NAME=>'cf2'}

2,向表中新增資料,在想HBase的表中新增資料的時候,只能一列一列的新增,不能同時新增多列。

hbase(main):042:0> put'hbase_1102', '001','cf1:name','Tom'
hbase(main):043:0> put'hbase_1102', '001','cf1:gender','man'
hbase(main):044:0> put'hbase_1102', '001','cf2:chinese','90'
hbase(main):045:0> put'hbase_1102', '001','cf2:math','91'

 

這樣表結構就起來了,其實比較自由,列族裡邊可以自由新增子列很方便。如果列族下沒有子列,加不加冒號都是可以的。

如果在新增資料的時候,需要手動的設定時間戳,則在put命令的最後加上相應的時間戳,時間戳是long型別的,所以不需要加引號

hbase(main):045:0> put'hbase_1102', '001','cf2:math','91',1478053832459

3,查看錶中的所有資料

hbase(main):046:0> scan 'hbase_1102'
ROW   COLUMN+CELL                                                             
 001  column=cf1:gender, timestamp=1478053832459, value=man                   
 001  column=cf1:name, timestamp=1478053787178, value=Tom                     
 001  column=cf2:chinese, timestamp=1478053848225, value=90001  column=cf2:math, timestamp=1478053858144, value=911 row(s) in0.0140seconds

4,檢視其中某一個Key的資料

hbase(main):048:0> get'hbase_1102','001'
COLUMN                    CELL                                                                    
 cf1:gender               timestamp=1478053832459, value=man                                      
 cf1:name                 timestamp=1478053787178, value=Tom                                      
 cf2:chinese              timestamp=1478053848225, value=90                                       
 cf2:math                 timestamp=1478053858144, value=914 row(s) in0.0290seconds

------------------------------------------------------

Hbase刪除表

用drop命令可以刪除表。在刪除一個表之前必須先將其禁用。

hbase(main):018:0> disable 'emp'
0 row(s) in 1.4580 seconds


hbase(main):019:0> drop 'emp'
0 row(s) in 0.3060 seconds

使用exists 命令驗證表是否被刪除。

hbase(main):020:0> exists 'emp'
Table emp does not exist

0 row(s) in 0.0730 seconds

drop_all

這個命令是用來在給出刪除匹配“regex”表。它的語法如下:

hbase> drop_all ‘t.*’ 

注意:要刪除表,則必須先將其禁用。

示例

假設有一些表的名稱為raja, rajani, rajendra, rajesh, 和 raju。

hbase(main):017:0> list
TABLE
raja
rajani
rajendra 
rajesh
raju
9 row(s) in 0.0270 seconds

所有這些表以字母raj開始。首先使用disable_all命令禁用所有這些表如下所示。

hbase(main):002:0> disable_all 'raj.*'
raja
rajani
rajendra
rajesh
raju
Disable the above 5 tables (y/n)?
y
5 tables successfully disabled

現在,可以使用 drop_all 命令刪除它們,如下所示。

hbase(main):018:0> drop_all 'raj.*'
raja
rajani
rajendra
rajesh
raju

Drop the above 5 tables (y/n)?

y
5 tables successfully dropped

使用Java API刪除表

可以使用 HBaseAdmin 類的deleteTable()方法刪除表。按照下面給出是使用Java API來刪除表中的步驟。

第1步

例項化HBaseAdmin類。

// creating a configuration object
Configuration conf = HBaseConfiguration.create();

// Creating HBaseAdmin object
HBaseAdmin admin = new HBaseAdmin(conf); 

第2步

使用HBaseAdmin類的disableTable()方法禁止表。

admin.disableTable("emp1");

第3步

現在使用HBaseAdmin類的deleteTable()方法刪除表。

admin.deleteTable("emp12");

下面給出的是完整的Java程式用於刪除HBase表。

import java.io.IOException;

import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.client.HBaseAdmin;

public class DeleteTable {

   public static void main(String[] args) throws IOException {

      // Instantiating configuration class
      Configuration conf = HBaseConfiguration.create();

      // Instantiating HBaseAdmin class
      HBaseAdmin admin = new HBaseAdmin(conf);

      // disabling table named emp
      admin.disableTable("emp12");

      // Deleting emp
      admin.deleteTable("emp12");
      System.out.println("Table deleted");
   }
}

編譯和執行上述程式如下所示。

 

$javac DeleteTable.java
$java DeleteTable

下面是輸出結果:

Table deleted