使用 Java API 在 Hbase 中创建表

Question

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

public class CreateTable {

    public static void main(String[] args) throws IOException {
        Configuration con = HBaseConfiguration.create();
        HBaseAdmin admin = new HBaseAdmin(con);

        HTableDescriptor ht = new HTableDescriptor("emp");

        ht.addFamily(new HColumnDescriptor("add"));
        ht.addFamily(new HColumnDescriptor("dept"));

        admin.createTable(ht);

        System.out.println("Table Created");
    }
}

我已经使用上面的代码创建了 Hbase 表。我已经下载了所有需要的罐子，并将它们添加为出现错误时。但是仍然收到很多与动物园管理员相关的错误。 我的疑问是，在创建表之前我是否必须使用 JAVA API 连接 Zookeeper。我正在使用 JDK 1.8 请指导我使用 JAVA API 在 Hbase 中创建表的确切过程。这些是 Zookeeper 遇到的以下错误，但我添加了 Zookeeper Jar。 17/12/11 12:44:10 INFO zookeeper.ZooKeeper：客户端环境：zookeeper.version=3.3.1-942149，建于 05/07/2010 17:14 GMT 17/12/11 12:44:10 INFO zookeeper.ZooKeeper：客户端环境：host.name=quickstart.cloudera 17/12/11 12:44:10 INFO zookeeper.ZooKeeper：客户端环境：java.version=1.8.0_144 17/12/11 12:44:10 INFO zookeeper.ZooKeeper：客户端环境：java.vendor=Oracle Corporation 17/12/11 12:44:10 INFO zookeeper.ZooKeeper：客户端环境：java.home=/home/cloudera/jdk1.8.0_144/jre 17/12/11 12:44:10 INFO zookeeper.ZooKeeper：客户端环境：java.class.path=/home/cloudera/workspace/HbaseTbl/bin:/home/cloudera/Downloads/apache-logging-log4j.jar： /home/cloudera/Downloads/hadoop-core-0.20.2-cdh3u0.jar:/home/cloudera/Downloads/hbase-0.94.0.jar:/home/cloudera/Downloads/org-apache-commons-logging.jar :/home/cloudera/Downloads/zookeeper.jar 17/12/11 12:44:10 INFO zookeeper.ZooKeeper：客户端环境：java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib

Answer 1

这是对我来说很好用的代码：

        conf = HBaseConfiguration.create();
        admin = new HBaseAdmin(conf);

        TableName tableName =  TableName.valueOf("test");
        HTableDescriptor htd = new HTableDescriptor(tableName);
        HColumnDescriptor hcd = new HColumnDescriptor("data");

        htd.addFamily(hcd);
        admin.createTable(htd);

并且还在 bash_profile 中添加以下环境变量

export HADOOP_HOME=/Users/karan.verma/Documents/backups/h/hadoop-2.6.4
export PATH=$PATH:$HADOOP_HOME/bin
export PATH=$PATH:$HADOOP_HOME/sbin
export HADOOP_PREFIX=/Users/karan.verma/Documents/backups/h/hadoop-2.6.4
export HADOOP_CONF_DIR=$HADOOP_HOME/etc/hadoop
export HADOOP_MAPRED_HOME=$HADOOP_HOME
export HADOOP_COMMON_HOME=$HADOOP_HOME
export HADOOP_HDFS_HOME=$HADOOP_HOME
export YARN_HOME=$HADOOP_HOME

export HADOOP_COMMON_LIB_NATIVE_DIR=$HADOOP_HOME/lib/native
export HADOOP_OPTS="-Djava.library.path=$HADOOP_HOME/lib"
export HADOOP_CLASSPATH=${JAVA_HOME}/lib/tools.jar