HBase之创建表

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

import org.apache.hadoop.hbase.filter.Filter;

import org.apache.hadoop.hbase.filter.PageFilter;

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

import java.io.IOException;

/**

 * Hbase 创建表

 */

public class CreateTableInHbase {

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

        Configuration conf = HBaseConfiguration.create();

        Connection connection = ConnectionFactory.createConnection(conf);

        //管理员对象

        Admin admin = connection.getAdmin();

        //表名

        TableName tableName = TableName.valueOf("testtable2");

        //表描述

        HTableDescriptor desc = new HTableDescriptor(tableName);

        //列族描述

        HColumnDescriptor coldef = new HColumnDescriptor(Bytes.toBytes("colfam1"));

        //表加入列族

        desc.addFamily(coldef);

        //创建表

        admin.createTable(desc);

        //校验表是否可用

        boolean avail = admin.isTableAvailable(tableName);

        System.out.println("Table available: "+avail);

    }

}

/**

 preHell:

 hbase(main):001:0> list

 TABLE

 user

 1 row(s) in 0.2670 seconds

 => ["user"]

====================================>

Java output:

 Table available: true

========

 nextShell:

 hbase(main):005:0> list

 TABLE

 testtable2

 user

 2 row(s) in 0.0070 seconds

 hbase(main):006:0> desc 'testtable2'

 Table testtable2 is ENABLED

 testtable2

 COLUMN FAMILIES DESCRIPTION

 {NAME => 'colfam1', DATA_BLOCK_ENCODING => 'NONE', BLOOMFILTER => 'ROW', REPLICATION_SCOPE => '0', VERSIONS => '1', COMPRESSION => 'NONE', MIN_VERSIONS => '0',

 TTL => 'FOREVER', KEEP_DELETED_CELLS => 'FALSE', BLOCKSIZE => '65536', IN_MEMORY => 'false', BLOCKCACHE => 'true

 **/
相关文章
