Hbase表空間簡介

1、介紹

Hbase中命名空間類似於傳統數據庫RDBMS中的：庫，方便對表進行業務上的划分。在hbase從0.98.0,0.95.2開始支持namespace級別的授權操作。hbase的全局管理員可以進行namespace的授權操作（創建、修改和回收）。 

2、namespace

HBase系統默認定義了兩個命名空間

hbase：系統內建表，包括namespace和meta表

default：用戶建表時未指定namespace的表都創建在此

 

3、namespace的基本操作，

　　操作思路類似於操作傳統數據庫

 

3.1：創建namespace:

　　hbase(main):010:0* create_namespace 'tablemamager' 

 

3.2：查看namespace:

　　hbase(main):011:0> describe_namespace 'tablemamager'

  　　DESCRIPTION              

  　　{NAME =>'tablemamager'}                                                                                                                

3.3：列出所有namespace:

　　hbase(main):012:0> list_namespace

    　NAMESPACE

    　　　tablemamager

    　　　default  

        　　hbase   

 

4、namespace下操作表

4.1：在namespace下創建表:       

　　hbase(main):013:0> create 'tablemamager:idbctable','cf01'

    　=> Hbase::Table - tablemamager:idbctable

4.1：查看namespace下的表

　　hbase(main):015:0> list_namespace_tables 'tablemamager'

    　　TABLE                

    　　idbctable   

 

4.2：刪除namespace:

　　#刪除表

　　hbase(main):017:0> disable 'tablemamager:idbctable'

　　hbase(main):018:0> drop 'tablemamager:idbctable'

　　#刪除datamanage命名空間

　　hbase(main):019:0> drop_namespace 'tablemamager'

 

JAVA API
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.util.Bytes;
 
import java.io.IOException;
 
 
/**
 * Hbase namespace
 */
public class NameSpaceInHbase {
    public static void main(String[] args) throws IOException {
 
        Configuration conf = HBaseConfiguration.create();
        Connection connection = ConnectionFactory.createConnection(conf);
        //管理員對象
        Admin admin = connection.getAdmin();
        //創建命名空間
        NamespaceDescriptor namespaceDescriptor = NamespaceDescriptor.create("datastrom3").build();
        admin.createNamespace(namespaceDescriptor);
        //表名
        TableName tableName = TableName.valueOf("datastrom3","testtable3");
        //表描述
        HTableDescriptor desc = new HTableDescriptor(tableName);
        //列族描述datastrom
        HColumnDescriptor coldef = new HColumnDescriptor(Bytes.toBytes("colfam3"));
        //表加入列族
        desc.addFamily(coldef);
        //創建表
        admin.createTable(desc);
        //校驗表是否可用
        boolean avail = admin.isTableAvailable(tableName);
        System.out.println("Table available: "+avail);
    }
}
 
/**
 preHell:
 ========
 nextShell:
 hbase(main):005:0> list
 TABLE
 testtable2
 user
 2 row(s) in 0.0070 seconds
 
java output:
 =====
 Table available: true
 
shell:
 =====
 hbase(main):022:0> list
 TABLE
 datastrom3:testtable3
 ...
  **/