您的位置:首页 > 编程语言 > Java开发

java client 连接hbase报错,超时

2017-09-22 15:19 393 查看
public static Configuration configuration;
static {
configuration = HBaseConfiguration.create();
configuration.set("hbase.zookeeper.property.clientPort", "2181");
configuration.set("hbase.zookeeper.quorum", "mypc1,mypc1"); /////////不能使用ip地址,只能使用hostname,修改etc/hosts
configuration.set("hbase.master", "192.168.2.13:600000");
}

public static void main(String[] args) {
// createTable("qikun");
// insertData("qikun");
QueryAll("peopleVT.");
// QueryByCondition1("qikun");
// QueryByCondition2("qikun");
// QueryByCondition3("qikun");
// deleteRow("qikun","abcdef");
// deleteByCondition("qikun", "abcdef");
}

public static void createTable(String tableName) {
System.out.println("start create table ......");
try {
HBaseAdmin hBaseAdmin = new HBaseAdmin(configuration);
if (hBaseAdmin.tableExists(tableName)) {// 如果存在要创建的表,那么先删除,再创建
hBaseAdmin.disableTable(tableName);
hBaseAdmin.deleteTable(tableName);
System.out.println(tableName + " is exist,detele....");
}
HTableDescriptor tableDescriptor = new HTableDescriptor(tableName);
tableDescriptor.addFamily(new HColumnDescriptor("column1"));
tableDescriptor.addFamily(new HColumnDescriptor("column2"));
tableDescriptor.addFamily(new HColumnDescriptor("column3"));
hBaseAdmin.createTable(tableDescriptor);
} catch (MasterNotRunningException e) {
e.printStackTrace();
} catch (ZooKeeperConnectionException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
System.out.println("end create table ......");
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: