HBase 根據表名與列資訊與配置資訊建立表
阿新 • • 發佈:2019-01-03
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(); }
歡飲加入微信群聊-【聊技術、聊生活】