donghao19944
donghao19944
采纳率59.1%
2019-02-13 10:51 阅读 762

hbase eclipse上创建hbase简单表

5

图片说明
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();

    }
}

}


  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享

2条回答 默认 最新

  • weixin_44168621 weixin_44168621 2019-02-13 14:07

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

    点赞 评论 复制链接分享
  • jiannanchong jiannanchong 2019-02-13 18:23

    1、先确定hbase是否已经启动
    2、把连接信息加了,给你一个参考
    图片说明

    点赞 评论 复制链接分享

相关推荐