Hbase基本API的使用

package test;

import java.util.Map;
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.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;


public class HbaseDemo 
{
    //HBase是基于Hadoop的开源数据库，他以Google的BigTable为原型实现的
    //Region服务器
    //HBase在行的方向上将表分成多个Region，每个Region包含一定范围内的数据。随着表中的数据不断的增加    
    //一个Region会被分成多个新的Region
    //Region是HBase中分布式存储和负载均衡的最小单位，即一个表所有的Region会被分到多个Region服务器上
    //每个Region由一个或多个Store组成，每个Store保存一个列族的所有的数据，
    //每个Store由一个或多个memStore组成
     
    //主服务器
    //HBase每个时刻只有一个HMaster(主服务器程序)在运行HMaster将Region分配给Region服务器
    public static void main(String[] args) throws Exception{
    Configuration conf = HBaseConfiguration.create(); //初始化HBase的配置文件
    conf.set("hbase.zookeeper.quorum", "UbubtuSlave1,UbuntuSlave2,UbuntuSlave3");//指定HBase使用的Zookeeper的地址
    HBaseAdmin admin = new HBaseAdmin(conf);//实例化HBaseAdmin(该类用于对表的元数据进行操作并提供了基本的管理操作)

    HTableDescriptor tableDescriptor = new HTableDescriptor("tab1".getBytes());
    tableDescriptor.addFamily(new HColumnDescriptor("fam1"));
    admin.createTable(tableDescriptor);//创建一张新表，参数为类HTableDescriptor，其中是对表名和相关的列族的描述
    HTable table = new HTable(conf,"tab1"); //可对表进行相关操作的类

    Put putRow1 = new Put("row1".getBytes());//可以向表中插入数据，初始化时可以传递一个行键，表示向那一行插入数据
    putRow1.add("fam1".getBytes(), "coll".getBytes(),"vall".getBytes());//插入数据
    table.put(putRow1);

    System.out.println("add row2");
    Put putRow2 = new Put("row2".getBytes());
    putRow2.add("fam1".getBytes(), "col2".getBytes(), "val2".getBytes());
    putRow2.add("fam1".getBytes(), "col3".getBytes(), "val3".getBytes());
    table.put(putRow2);

    for(Result row:table.getScanner("fam1".getBytes()))//table.getScanner获得某一列族的所有数据，方法返回Result类
    {
        System.out.format("ROW\t%s\n", new String(row.getRow()));
        for(Map.Entry<byte[],byte[]> entry :row.getFamilyMap("fam1".getBytes()).entrySet())
        {
            //Result.getFamilyMap()可以获得以列名为key值为value的映射表
            String column = new String(entry.getKey());
            String value = new String(entry.getValue());
            System.out.format("COLUMN\tfam1:%s\t%s\n", column,value);
        }
      }

    admin.disableTable("tab1");//删除表tab1
    admin.deleteTable("tab1");//删除表tab1
    }
}