我正在尝试从java客户端api获取hbase中的连接。
这是我的密码。在这里,我编写了一些代码来获取hbase中的连接。
我没有得到任何错误,当我运行这个代码。但我不能用这个创建任何表格。
Configuration hbaseConfiguration = HBaseConfiguration.create();
try {
hbaseConfiguration.set("hbase.rootdir",
"file:///home/sample/hbase");
hbaseConfiguration.set("hbase.zookeeper.property.dataDir",
"/home/sample/zookeeper");
hbaseConfiguration.set("hbase.zookeeper.quorum",
"sample");
Configuration newConfig = new Configuration(hbaseConfiguration);
HConnection connection = HConnectionManager
.getConnection(newConfig);
hBaseAdmin = new HBaseAdmin(connection);
hBaseAdmin.createTable(new HTableDescriptor("sample"));
if (!hBaseAdmin.isMasterRunning())
throw new Exception("Hbase is not running");
tableFactory = new HTableFactory();
} catch (Exception e) {
throw new Exception("Hbase is not running");
}
有人能帮我吗??谢谢。。。。
2条答案
按热度按时间ruyhziif1#
更改以下代码
到
注:
rs1.example.com
应该替换为zookeeper群集的地址点。你可以在你的生活中找到价值conf/hbase-site.xml
.pkwftd7m2#
这个
hbase.rootdir
设置将被完全忽略。只能在hbase-site.xml文件中设置。