hadoop - 尝试通过Java访问HBase时出错

Question

我正在尝试通过Java将数据写入HBase。这是我正在使用的代码:

import java.io.IOException;
import org.apache.hadoop.conf.Configurable;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.util.Bytes;


public class MyLittleHBaseClient 
{
    public static void main(String[] args) throws IOException 
    {
        HBaseConfiguration config = new HBaseConfiguration();
        HTable table = new HTable(config, "myLittleHBaseTable");
        Put p = new Put(Bytes.toBytes("myLittleRow"));
        p.add(Bytes.toBytes("myLittleFamily"), Bytes.toBytes("someQualifier"),
        Bytes.toBytes("Some Value"));
        table.put(p);
    }
}

我尝试将 conf.set("hbase.master","localhost:51310")放在我的Hbase主服务器运行的位置51310上。我的区域服务器位于 "localhost:13184"上。以上代码与我在互联网上发现的非常相似，唯一的问题是 HBaseConfiguration.create()表示“没有这种方法”。
遇到的错误是org.apache.hadoop.hbase.client.NoServerForRegionException:尝试定位根区域超时。我的IDE是oracle Jdeveloper。我添加了所有jar文件，并且jps显示了所有服务器运行良好。我不知道我在做什么错。互联网上的所有示例在其代码中均显示了 HBaseConfiguration.create()。我使用了Hbase-0.90.4

Answer 1

对代码进行一些更改即可使其运行。

更改以下内容:

 HBaseConfiguration config = new HBaseConfiguration();

至:

Configuration config = HBaseConfiguration.create();

如果您要连接到本地主机，则只需如上所述设置 hbase.master的值即可。如果要连接到远程HBase存储，请进行以下设置:

conf.set("hbase.zookeeper.quorum","<host name>")

还有这个

conf.set("hbase.zookeeper.property.clientPort","<client port used by zookeeper>")

最后添加

conf.set("hbase.master","<host name>:<port>")

第一步，在您的主机文件(在Linux中为/ etc / hosts)中设置适当的主机名，并将其设置为计算机的IP地址。现在，将该主机名作为zookeeper仲裁的值。这一步很重要，因为 HBase仅识别主机名，而不识别IP地址。

第二步，通过检查 / hbase / conf 目录下的配置文件，找出Zookeeper使用的客户端端口。