hbase eclipse上创建hbase简单表

Question

public class HbaseForJava {

//根据hbase的配置参数，创建目标zookeeper hbase连接
public static Configuration conf = HBaseConfiguration.create();

public static TableName  tableName = TableName.valueOf("table123");

public static void main(String[] args) {
    createTable();
}

private static void createTable() {

    try (
        Connection conn = ConnectionFactory.createConnection(conf);
        //根据连接，获取表的管理对象
        HBaseAdmin admin = (HBaseAdmin) conn.getAdmin();
        )
    {
        //安全校验 表存在 不创建
        if(admin.tableExists(tableName)){
            System.out.println("tableName"+tableName.toString()+"exists!");
            return;
        }
        // new 表描述对象
        HTableDescriptor table = new HTableDescriptor(tableName);

        //new 表里面的列族
        HColumnDescriptor cf1 = new HColumnDescriptor(Bytes.toBytes("cf1"));
        HColumnDescriptor cf2 = new HColumnDescriptor(Bytes.toBytes("cf2"));

        //给表添加列族
        table.addFamily(cf1);
        table.addFamily(cf2);
        admin.createTable(table);
        System.out.println("create table"+tableName.toString()+"success");
    } catch (IOException e) {

        e.printStackTrace();

    }
}

}

Answer 1

没连接上吧
conf.set("hbase.zookeeper.quorum", "master");// 使用eclipse时必须添加这个，否则无法定位master需要配置hosts
conf.set("hbase.zookeeper.property.clientPort", "2181");