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.*;import org.apache.hadoop.hbase.filter.Filter;import org.apache.hadoop.hbase.filter.PageFilter;import org.apache.hadoop.hbase.util.Bytes;import java.io.IOException;/** * Hbase 创建表 */public class CreateTableInHbase { public static void main(String[] args) throws IOException { Configuration conf = HBaseConfiguration.create(); Connection connection = ConnectionFactory.createConnection(conf); //管理员对象 Admin admin = connection.getAdmin(); //表名 TableName tableName = TableName.valueOf("testtable2"); //表描述 HTableDescriptor desc = new HTableDescriptor(tableName); //列族描述 HColumnDescriptor coldef = new HColumnDescriptor(Bytes.toBytes("colfam1")); //表加入列族 desc.addFamily(coldef); //创建表 admin.createTable(desc); //校验表是否可用 boolean avail = admin.isTableAvailable(tableName); System.out.println("Table available: "+avail); }}/** preHell: hbase(main):001:0> list TABLE user 1 row(s) in 0.2670 seconds => ["user"]====================================>Java output: Table available: true======== nextShell: hbase(main):005:0> list TABLE testtable2 user 2 row(s) in 0.0070 seconds hbase(main):006:0> desc 'testtable2' Table testtable2 is ENABLED testtable2 COLUMN FAMILIES DESCRIPTION {NAME => 'colfam1', DATA_BLOCK_ENCODING => 'NONE', BLOOMFILTER => 'ROW', REPLICATION_SCOPE => '0', VERSIONS => '1', COMPRESSION => 'NONE', MIN_VERSIONS => '0', TTL => 'FOREVER', KEEP_DELETED_CELLS => 'FALSE', BLOCKSIZE => '65536', IN_MEMORY => 'false', BLOCKCACHE => 'true **/