创建表

    1. package com.zykj.hbase.back.utils;
    3. import org.apache.hadoop.conf.Configuration;
    4. import org.apache.hadoop.hbase.HBaseConfiguration;
    5. import org.apache.hadoop.hbase.HColumnDescriptor;
    6. import org.apache.hadoop.hbase.HTableDescriptor;
    7. import org.apache.hadoop.hbase.TableName;
    8. import org.apache.hadoop.hbase.client.Connection;
    9. import org.apache.hadoop.hbase.client.HBaseAdmin;
    10. import org.apache.hadoop.hbase.client.Table;
    11. import org.junit.Test;
    13. import java.io.IOException;
    15. /**
    16.  * description
    17.  *
    18.  * @author ${user}
    19.  * @Time 2019-04-10
    20.  */
    21. public class HbaseUtil {
    22.     static Configuration config = null;
    23.     private Connection connection = null;
    24.     private Table table = null;
    25.     private String zk_ip = null;
    26.     private String zi_port = null;
    29.     {
    30.         PropertiesUtils propertiesUtils = new PropertiesUtils();
    31.         zk_ip = propertiesUtils.getProperty("zookeeper_ip");
    32.         zi_port = propertiesUtils.getProperty("zookeeper_port");
    34.         config = HBaseConfiguration.create();// 配置
    35.         config.set("hbase.zookeeper.quorum", zk_ip); // zookeeper地址
    36.         config.set("hbase.zookeeper.property.clientPort", zi_port);// zookeeper端口
    37.     }
    39.     public boolean createTable() {
    41.         HBaseAdmin admin = null; // hbase表管理
    42.         try {
    43.             admin = new HBaseAdmin(config);
    44.         } catch (IOException e) {
    45.             e.printStackTrace();
    46.         }
    48.         // 创建表描述类
    49.         TableName tableName = TableName.valueOf("dept"); // 表名称
    50.         HTableDescriptor desc = new HTableDescriptor(tableName);
    51.         // 创建列族的描述类
    52.         HColumnDescriptor family = new HColumnDescriptor("info"); // 列族
    53.         // 将列族添加到表中
    54.         desc.addFamily(family);
    55.         HColumnDescriptor family2 = new HColumnDescriptor("subdept"); // 列族
    56.         // 将列族添加到表中
    57.         desc.addFamily(family2);
    59. //        System.out.println("judgement");
    61.         // 创建表
    62.         try {
    63.             admin.createTable(desc); // 创建表
    64.         } catch (IOException e) {
    65.             e.printStackTrace();
    66.         }
    67.         System.out.println("创建表成功！");
    68.         return true;
    69.     }
    71.     @Test
    72.     public void TestCreateT() {
    73.         HbaseUtil hbaseUtil = new HbaseUtil();
    74.         hbaseUtil.createTable();
    75.     }
    77. }