hbase学习--1 使用 java api 创建表

项目中用到的数据库时hbase,因此学习一下hbase的基本操作。

1  hbase是使用java编写的,使用java  api很对hbase进行操作,首先创建一个hbase表。

我的java工程使用maven管理的,hbase对应的maven依赖为

        <dependency>
            <groupId>org.apache.hadoop</groupId>
            <artifactId>hadoop-hdfs</artifactId>
            <version>2.2.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.hbase</groupId>
            <artifactId>hbase-common</artifactId>
            <version>1.2.6</version>
        </dependency>
        <dependency>
            <groupId>org.apache.hbase</groupId>
            <artifactId>hbase-client</artifactId>
            <version>1.2.6</version>
        </dependency>

注意hbase的版本和maven中的版本对应,否则会出现异常。

使用HBaseAdmin类的createTable()方法来创建表,下面是创建表的代码

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 java.io.IOException;

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

        //第一步:实例化HbaseAdmin
        Configuration conf = HBaseConfiguration.create();
	HBaseAdmin admin = new HBaseAdmin(conf);

        //第二步:添加表描述 
	HTableDescriptor tableDescriptor = new HTableDescriptor(TableName.valueOf("People"));

        tableDescriptor.addFamily(new HColumnDescriptor("personal data"));
        tableDescriptor.addFamily(new HColumnDescriptor(("professional data")));

	//第三步:创建表
        admin.createTable(tableDescriptor);
        System.out.println("Table created");
    }
}

对应的HBase shell命令来创建表。

create 'People', 'personal data', 'professional data'

 


版权声明:本文为wslyk606原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。