学步园

本文由两篇文章结合而得：

http://hi.baidu.com/cpuramdisk/item/007bb0d35bc7d9322b35c723

http://www.cnblogs.com/ggjucheng/p/3380267.html

首先看一下当前几个相关的Java API与HBase数据模型之间的对应关系：

一、HBaseConfiguration

关系：org.apache.hadoop.hbase.HBaseConfiguration

作用：对HBase进行配置

在使用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对象。
        Configuration.set(String name, String value) 

用法示例：

HBaseConfiguration hconfig = new HBaseConfiguration();
hconfig.set("hbase.zookeeper.property.clientPort","2181");

该方法设置了"hbase.zookeeper.property.clientPort"的端口号为2181。一般情况下，HBaseConfiguration会使用构造函数进行初始化，然后在使用其他方法。

二、HBaseAdmin

关系：org.apache.hadoop.hbase.client.HBaseAdmin

作用：提供了一个接口来管理HBase数据库的表信息。它提供的方法包括：创建表，删除表，列出表项，使表有效或无效，以及添加或删除表列族成员等。

用法示例：

HBaseAdmin admin=newHBaseAdmin(config);  
If(!admin.tableExists(“test”)){ 
   HTableDescriptor tableDesc=new HTableDescriptor(“test”);  
   HColumnDescriptor cf=new HColumnDescriptor(“cf”);  
   tableDesc.addFamily(cf);  
   admin.createTable(tableDesc);  
} 

三、HTableDescriptor

关系：org.apache.hadoop.hbase.HTableDescriptor

作用：包含了表的名字极其对应表的列族

用法示例：

HTableDescriptor htd= new HTableDescriptor(table);
htd.addFamily(new HcolumnDescriptor("family"));

在上述例子中，通过一个HColumnDescriptor实例，为HTableDescriptor添加了一个列族：family

四、HColumnDescriptor

关系：org.apache.hadoop.hbase.HColumnDescriptor

作用：维护着关于列族的信息，例如版本号，压缩设置等。它通常在创建表或者为表添加列族的时候使用。列族被创建后不能直接修改，只能通过删除然后重新创建的方式。列族被删除的时候，列族里面的数据也会同时被删除。

用法示例：

HTableDescriptor htd= new HTableDescriptor(tablename);
HColumnDescriptor col= new HColumnDescriptor("content:");
htd.addFamily(col);

此例添加了一个content的列族

五、HTable

关系：org.apache.hadoop.hbase.client.HTable

作用：可以用来和HBase表直接通信。此方法对于更新操作来说是非线程安全的。

在HBase中，HTable封装表格对象，对表格的增删改查操作主要通过它来完成，构造方法如下：
        HTable table=new HTable(config,tableName);
在构建多个HTable对象时，HBase推荐所有的HTable使用同一个Configuration。这样，HTable之间便可共享HConnection对象、zookeeper信息以及Region地址的缓存信息。

用法示例：

HTable table = newHTable(conf, Bytes.toBytes(tablename));
ResultScanner scanner=  table.getScanner(family);

六、Put

关系：org.apache.hadoop.hbase.client.Put

作用：用来对单个行执行添加操作

用法示例：

HTable table = newHTable(conf,Bytes.toBytes(tablename));
Put put=newPut(rowKey);  
put.add(columnFamily,column,value); 
table.put(put); 

七、Get

关系：org.apache.hadoop.hbase.client.Get

作用：用来获取单个行的相关信息

用法示例：

HTable table = newHTable(conf, Bytes.toBytes(tablename));
Get get=newGet(rowKey);  
Result res=table.get(get);  

八、Result

关系：org.apache.hadoop.hbase.client.Result

作用：存储Get或者Scan操作后获取表的单行值。使用此类提供的方法可以直接获取值或者各种Map结构（key-value对）

九、ResultScanner

关系：Interface

作用：客户端获取值的接口

用法示例：

Scan scan=new Scan();  
scan.addColumn(columnFamily,column);  //指定查询要返回的column   
SingleColumnValueFilterfilter=new SingleColumnValueFilter(  
       columnFamily,column,              //指定要过滤的column   
       CompareOp.EQUAL,value             //指定过滤条件   
);   
scan.setFilter(filter);                       //为查询指定过滤器   
ResultScanner scanner=table.getScanner(scan);//执行扫描查找   
Iterator<Result> res=scanner.iterator( );//返回查询遍历器