我需要通过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");