您好,登錄后才能下訂單哦!
這篇文章將為大家詳細講解有關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進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。