MapR-DB HBase java客户端代码

问题描述 投票:0回答:1

我需要通过Java代码连接MapR-DB(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");
java hbase mapr
1个回答
0
投票
  1. 您是否安装并配置了MapR客户端?客户端用于向您的代码指示它必须连接到哪个群集。

您可以找到安装说明:* MapR Client Setup

  1. 您是否有任何可以帮助我们调试您的问题的例外?
© www.soinside.com 2019 - 2024. All rights reserved.