HBase之Java API

1.Configuration

在使用Java API時，Client端需要知道HBase的配置環境，如存儲地址，zookeeper等信息。這些信息通過Configuration對象來封裝，可通過如下代碼構建該對象

        Configuration config=HBaseConfiguration.create();

在調用HBaseConfiguration.create()方法時，HBase首先會在classpath下查找hbase-site.xml文件，將裡面的信息解析出來封裝到Configuration對象中，如果hbase-site.xml文件不存在，則使用默認的hbase-core.xml文件。

除了將hbase-site.xml放到classpath下，開發人員還可通過config.set(name, value)方法來手工構建Configuration對象。

2.HBaseAdmin

HBaseAdmin用於創建數據庫表格，並管理表格的元數據信息，通過如下方法構建

        HBaseAdmin admin=new HBaseAdmin(config);

常用方法：

        addColumn(tableName,column):為表格添加欄位

        deleteColumn(tableName,column):刪除指定欄位

        balanceSwitch(boolean):是否啟用負載均衡

        createTable(HTableDescriptor desc):創建表格

        deleteTable(tableName):刪除表格

示例：創建test表格，並為其指定columnFamily為cf

[java]

1. HBaseAdmin admin=new HBaseAdmin(config);  
2. If(!admin.tableExists(“test”)){  
3.     HTableDescriptor tableDesc=new HTableDescriptor(“test”);  
4.     HColumnDescriptor cf=new HColumnDescriptor(“cf”);  
5.     tableDesc.addFamily(cf);  
6.     admin.createTable(tableDesc);  
7. }  

3.HTable

在HBase中，HTable封裝表格對象，對表格的增刪改查操作主要通過它來完成，構造方法如下：

        HTable table=new HTable(config,tableName);

在構建多個HTable對象時，HBase推薦所有的HTable使用同一個Configuration。這樣，HTable之間便可共享HConnection對象、zookeeper信息以及Region地址的緩存信息。

示例1：Get操作

[java]

1. Get get=new Get(rowKey);  
2. Result res=table.get(get);  

[java]

1. Put put=new Put(rowKey);  
2. put.add(columnFamily,column,value);  
3. table.put(put);  

示例3：Delete操作

[java]

1. Delete delete=new Delete()；  
2. table.delete(delete);  

[java]

1. Scan scan=new Scan( );  
2. scan.addColumn(columnFamily,column);//指定查詢要返回的column   
3. SingleColumnValueFilter filter=new SingleColumnValueFilter(  
4.         columnFamily,column,//指定要過濾的column   
5.         CompareOp.EQUAL,value//指定過濾條件   
6. );  
7. //更多的過濾器信息請查看org.apache.Hadoop.hbase.filter包   
8. scan.setFilter(filter);//為查詢指定過濾器   
9. ResultScanner scanner=table.getScanner(scan);//執行掃描查找   
10. Iterator<Result> res=scanner.iterator( );//返回查詢遍歷器