HBase管理和优化

import java.io.IOException;

import java.util.Arrays;

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

import org.apache.hadoop.hbase.client.ConnectionFactory;

import org.apache.hadoop.hbase.client.Get;

import org.apache.hadoop.hbase.client.Put;

import org.apache.hadoop.hbase.client.Result;

import org.apache.hadoop.hbase.client.Table;

import org.apache.hadoop.hbase.util.Bytes;

public class HBaseExample {

    private static final String TABLE_NAME = "test_table";

    private static final String COLUMN_FAMILY = "cf";

    private static final String COLUMN_QUALIFIER = "column";

    public static void main(String[] args) {

        try {

            // 创建HBase配置

            Configuration conf = HBaseConfiguration.create();

            conf.set("hbase.zookeeper.quorum", "localhost");

            // 创建HBase连接

            Connection conn = ConnectionFactory.createConnection(conf);

            // 创建表

            createTable(conn);

            // 插入数据

            putData(conn);

            // 查询数据

            getData(conn);

            // 关闭连接

            conn.close();

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

    private static void createTable(Connection conn) throws IOException {

        // 创建表描述符

        HTableDescriptor tableDesc = new HTableDescriptor(TableName.valueOf(TABLE_NAME));

        // 创建列族描述符

        HColumnDescriptor colDesc = new HColumnDescriptor(COLUMN_FAMILY);

        colDesc.setInMemory(true);

        // 添加列族描述符

        tableDesc.addFamily(colDesc);

        // 创建表

        conn.getAdmin().createTable(tableDesc);

    }

    private static void putData(Connection conn) throws IOException {

        // 获取表

        Table table = conn.getTable(TableName.valueOf(TABLE_NAME));

        // 创建Put对象

        Put put = new Put(Bytes.toBytes("row_key"));

        put.addColumn(Bytes.toBytes(COLUMN_FAMILY), Bytes.toBytes(COLUMN_QUALIFIER), Bytes.toBytes("value"));

        // 插入数据

        table.put(put);

        // 关闭表

        table.close();

    }

    private static void getData(Connection conn) throws IOException {

        // 获取表

        Table table = conn.getTable(TableName.valueOf(TABLE_NAME));

        // 创建Get对象

        Get get = new Get(Bytes.toBytes("row_key"));

        get.addColumn(Bytes.toBytes(COLUMN_FAMILY), Bytes.toBytes(COLUMN_QUALIFIER));

        // 查询数据

        Result result = table.get(get);

        byte[] value = result.getValue(Bytes.toBytes(COLUMN_FAMILY), Bytes.toBytes(COLUMN_QUALIFIER));

        // 输出查询结果

        System.out.println(Arrays.toString(value));

        // 关闭表

        table.close();

    }

}