eclipse連接cdh5-hbase-beta2測試案例

package org.apache.hadoop;

import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.MasterNotRunningException;
import org.apache.hadoop.hbase.ZooKeeperConnectionException;
import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.HConnection;
import org.apache.hadoop.hbase.client.HConnectionManager;
import org.apache.hadoop.hbase.client.HTableInterface;


public class HTest01 {
     public static Configuration configuration;   
     public static HConnection connection;
        static {   
            configuration = HBaseConfiguration.create();   
            configuration.set("hbase.zookeeper.property.clientPort", "2181");   
            configuration.set("hbase.zookeeper.quorum", "192.168.1.10,192.168.1.11,192.168.1.12");   
            configuration.set("hbase.master", "192.168.1.10:8020");  
            try {
                connection=HConnectionManager.createConnection(configuration);
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }   
     public static void main(String[] args) throws IOException {
         
         createTable("xijinping");   
        
    }
     public static void createTable(String tableName) {   
            System.out.println("start create table ......");   
            try {
                HBaseAdmin hBaseAdmin = new HBaseAdmin(configuration); 
                
                if (hBaseAdmin.tableExists(tableName)) {// 若是存在要建立的表，那麼先刪除，再建立   
                    hBaseAdmin.disableTable(tableName);   
                    hBaseAdmin.deleteTable(tableName);   
                    System.out.println(tableName + " is exist,detele....");   
                }   
                HTableDescriptor tableDescriptor = new HTableDescriptor(tableName);   
                tableDescriptor.addFamily(new HColumnDescriptor("column1"));   
                tableDescriptor.addFamily(new HColumnDescriptor("column2"));   
                hBaseAdmin.createTable(tableDescriptor);   
            } catch (MasterNotRunningException e) {   
                e.printStackTrace();   
            } catch (ZooKeeperConnectionException e) {   
                e.printStackTrace();   
            } catch (IOException e) {   
                e.printStackTrace();   
            }   
            System.out.println("end create table ......");   
        }   

}

 注意事項：mac須要在／etc/hosts文件下配置 Hbase Master地址域名映射

windows 修改C:\Windows\system32\etc\hosts文件，添加Hbase Master節點的域名及IP地址映射。