mapr db hbase java客户端代码

wsxa1bj1  于 2021-06-08  发布在  Hbase
关注(0)|答案(1)|浏览(284)

我需要通过java代码连接maprdb(hbase)。我在“/mapr/root/main/database”(路径)中有二进制表“table01”。maprcli引用了这个路径“/mapr/root”,我的完整表名是“/main/database/table01”。
下面的hbase shell命令工作正常,但当我运行java代码时,它在第4行停止,甚至没有显示任何错误消息,也终止了。

scan '/main/database/Table01'

我的java扫描代码:

1.Connection con = ConnectionFactory.createConnection(conf);
2.Table table = con.getTable(TableName.valueOf("/main/database/Table01"));
3.Scan scan = new Scan();
4.ResultScanner rs = table.getScanner(scan);

我的配置代码:这个配置值来自'conf/hbase site.xml'

static Configuration conf = HBaseConfiguration.create();
conf.set("hbase.zookeeper.quorum", "XXXX");
conf.set("hbase.zookeeper.property.clientPort", "XXXX");
conf.set("hbase.cluster.distributed","true");
conf.set("hbase.rootdir", "maprfs:///hbase");
ndh0cuux

ndh0cuux1#

您是否安装并配置了mapr客户端?客户机用于向代码指示它必须连接到哪个集群。
您可以找到安装说明:*mapr client setup
您有任何例外情况可以帮助我们调试您的问题吗?

相关问题