private static Configuration configuration=null;
    static{
        configuration= HBaseConfiguration.create();
        configuration.set("hbase.zookeeper.property.clientPort","2081");
        configuration.set("hbase.zookeeper.quorum","192.168.136.135");
        configuration.set("hbase.master","192.168.136.135:60000");
    }

    /**
     * HBase 根據表名與列資訊與配置資訊建立表
     * @param tableName   表名稱
     * @param clolumnsInfos  列集合
     * @param configuration   org.apache.hadoop.conf.Configuration  配置物件
     * @throws Exception
     */
    public static void createTable(String tableName, List<String> clolumnsInfos,Configuration configuration) throws Exception{
        HBaseAdmin hbaseAdmin=new HBaseAdmin(configuration);
        if(hbaseAdmin.tableExists(tableName)){
            //如果表存在
            hbaseAdmin.disableTable(tableName);
            //刪除表
            hbaseAdmin.deleteTable(tableName);
        }
        HTableDescriptor tableDescriptor=new HTableDescriptor(TableName.valueOf(tableName));
        //新增列族
        for(String column:clolumnsInfos){
            tableDescriptor.addFamily(new HColumnDescriptor(column));
        }
        hbaseAdmin.createTable(tableDescriptor);
        hbaseAdmin.close();
    }
 

歡飲加入微信群聊-【聊技術、聊生活】