HBase API 的使用（一）

package cn.itcast.bigdata.hbase;

import java.util.ArrayList;

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.TableName;

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.util.Bytes;

import org.junit.Test;

public class HbaseDao {

 //添加数据

    @Test

    public void insetTest() throws Exception{

        Configuration conf = HBaseConfiguration.create();

        conf.set("hbase.zookeeper.quorum", "hadoop04:2181,hadoop05:2181,hadoop06:2181");

        

        HTable nvsheng = new HTable(conf,"nvsheng");

        

        Put name = new Put(Bytes.toBytes("rk00001"));

        name.add(Bytes.toBytes("base_info"),Bytes.toBytes("name"),Bytes.toBytes("angelababy"));

        

        Put age = new Put(Bytes.toBytes("rk00001"));

        age.add(Bytes.toBytes("base_info"),Bytes.toBytes("age"),Bytes.toBytes(18));

        

        

        ArrayList<Put> puts = new ArrayList<>();

        

        puts.add(name);

        puts.add(age);

        

        nvsheng.put(puts);

    }

    

    //创建表

    public static void main(String[] args) throws Exception {

        Configuration conf = HBaseConfiguration.create();

        conf.set("hbase.zookeeper.quorum", "hadoop04:2181,hadoop05:2181,hadoop06:2181");

        

        HBaseAdmin admin = new HBaseAdmin(conf);

        

        TableName name = TableName.valueOf("nvsheng");

        

        HTableDescriptor desc = new HTableDescriptor(name);

        

        HColumnDescriptor base_info = new HColumnDescriptor("base_info");

        HColumnDescriptor extra_info = new HColumnDescriptor("extra_info");

        base_info.setMaxVersions(5);

        

        

        desc.addFamily(base_info);

        desc.addFamily(extra_info);

        

        admin.createTable(desc);

        

    }

}

来自为知笔记(Wiz)