您好,登录后才能下订单哦!
这篇文章将为大家详细讲解有关Windows Java代码如何远程访问HBase,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。
搭建maven工程,pom依赖如下:
<dependency>
<groupId>org.apache.hbase</groupId>
<artifactId>hbase-client</artifactId>
<version>1.2.0-cdh6.7.0</version>
</dependency>
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-hdfs</artifactId>
<version>2.6.0-cdh6.7.0</version>
</dependency>
由于我用的cdh版本的,默认源只包含常用依赖,故需要添加Cloudera提供的如下源:
<repositories>
<repository>
<id>cloudera</id>
<url>https://repository.cloudera.com/artifactory/cloudera-repos/</url>
</repository>
</repositories>
注意:Maven配置文件setting.xml如果配置了阿里镜像,会导致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就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。