当前位置: 代码迷 >> 综合 >> hbase example code
  详细解决方案

hbase example code

热度:33   发布时间:2023-12-21 16:25:53.0

本地连接hbase:

Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "localhost");
config.set("hbase.zookeeper.property.clientPort", "2181");
HBaseAdmin.checkHBaseAvailable(config);
HTable table = new HTable(config, "mytable");
System.out.println("Table testTable obtained!");

 

线上连接hbase:

config = HBaseConfiguration.create();
config.set("hbase.hbase.zookeeper.quorum", "192.168.1.1,192.168.1.2,192.168.1.3");
config.set("hbase.hbase.zookeeper.property.clientPort", "3325");
config.set("hbase.rpc.timeout", "60000");
config.set("hbase.client.retries.number", "3");
config.set("hbase.client.pause", "100");
config.set("hbase.rpc.timeout", "900000");
config.set("hbase.client.operation.timeout", "900000");
config.set("hbase.regionserver.lease.period", "900000");

 

 

  相关解决方案