项目中用到的数据库时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版权协议,转载请附上原文出处链接和本声明。