本文将详细解释Windows Java代码如何远程访问HBase。这篇文章的内容质量很高,所以边肖会分享给大家参考。希望你看完这篇文章后有所了解。
搭建maven工程,pom依赖如下:
dependency
groupIdorg.apache.hbase/groupId
artifactIdhbase-client/artifactId
version1.2.0-cdh6.7.0/version
/dependency
dependency
groupIdorg.apache.hadoop/groupId
artifactIdhadoop-hdfs/artifactId
version2.6.0-cdh6.7.0/version
/dependency
由于我使用的是cdh版本,默认的源代码只包含公共依赖项,因此我需要添加Cloudera提供的以下源代码:
repositories
repository
idcloudera/id
urlhttps://repository.cloudera.com/artifactory/cloudera-repos//url
/repository
/repositories
注意:如果maven配置文件setting.xml配置了Ali映像,则无法下载与CDH相关的jar包,因此使用Maven默认映像。
建立连接
伪代码如下:
public class HbaseBaseClient {
private static Configuration confHbase = null;
private static Connection connection = null;
{
confHbase = HBaseConfiguration.create();
confHbase.setLong("hbase.rpc.timeout", 600000);
confHbase.setLong("hbase.client.scanner.caching", 1000);
confHbase.set("hbase.zookeeper.quorum", zknode);
confHbase.set("hbase.zookeeper.property.clientPort", "2181");
// No FileSystem for schema : hdfs
confHbase.set("fs.hdfs.impl","org.apache.hadoop.hdfs.DistributedFileSystem");
try {
connection=ConnectionFactory.createConnection(confHbase);} catch (IOException e) {e.printStackTrace();}}}
只需配置zk地址,也可以通过Master访问。
最重要一步:
配置hosts文件!!!!
所有的主机都要配置!!!!
不然会这样的如下错误:
java.net.UnknownHostException: unknown host
这样就可以写出添加、删除、检查的代码,然后右键执行run命令!
当然,你必须能够ping通服务器!有些内部网无法访问!调试应该用其他方法!我以后再说吧!
以上就是Windows Java代码如何远程访问HBase的全部内容。希望
内容来源网络,如有侵权,联系删除,本文地址:https://www.230890.com/zhan/113756.html