在使用Hadoop Java API访问HDFS集群时,在创建FileSystem对象时,直接指定NameNode的IP以及端口号即可。但是在HA模式下,访问HDFS集群却有一些不同,需要指定NameSpace和主备NameNode的IP以及端口等信息,具体操作方式见如下代码:

Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://ns1");
conf.set("dfs.nameservices", "ns1");
conf.set("dfs.ha.namenodes.ns1", "nn1,nn2");
conf.set("dfs.namenode.rpc-address.ns1.nn1", "namenode1:9000");
conf.set("dfs.namenode.rpc-address.ns1.nn2", "namenode2:9000");
//conf.setBoolean(name, value);
conf.set("dfs.client.failover.proxy.provider.ns1", "org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider");
FileSystem fs = FileSystem.get(new URI("hdfs://ns1"), conf, "hadoop");

另外还可以将Hadoop的配置文件core-site.xml和hdfs-site.xml拷到程序目录下,以输入流的方式加载到Configuration配置信息中。在实际工作中可能没有使用core-site.xml和hdfs-site.xml的权限,所以还是使用第一种方法。

Java API 访问HA模式下的HDFS集群相关推荐

  1. Java API访问HA方式的HDFS

    1.介绍 对于namenode是HA高可用集群时,客户端远程访问hdfs有两种实现方法: (1)将所有关于namenode的参数写入Configuration对象中 (2)将配置文件core-site ...

  2. 阿里云环境下搭建HadoopHA集群

    阿里云环境下搭建HadoopHA集群 1. HadoopHA介绍 1.1 hadoop高可用集群的简介 ​ hadoop是一个海量数据存储和计算的平台,能够存储PB级以上的数据,并且利用MapRedu ...

  3. HDFS 集群的机架感知

    HDFS 集群的机架感知 1.背景 1.1.Hadoop 的设计目的 1.2.Hadoop 的设计考虑 1.3.副本存放策略 2.配置机架感知 2.1.修改配置文件 core-site.xml 2.2 ...

  4. Java API访问HDFS集群(HA)

    title: Java API访问HDFS集群(HA) date: 2021-06-23 17:06:11 tags: HDFS hadoopV2版本及以后都是HA架构,active namenode ...

  5. HDFS HA模式下支持只连接其中Active的NameNode

    HDFS HA模式下支持只连接其中Active的NameNode:

  6. 使用Java API访问HFDS

    目录 1.概述 2.客户端核心类 3.代码实现 3.1.使用IDEA创建一个Maven项目 3.2.配置pom.xml文件 3.3.编写代码 1.概述 HDFS在生产应用中主要是Java客户端的开发, ...

  7. Hadoop(八)Java程序访问HDFS集群中数据块与查看文件系统

    阅读目录(Content) 一.HDFS中数据块概述 1.1.HDFS集群中数据块存放位置 1.2.数据块(data block)简介 1.3.对分布式文件系统中的块进行抽象会带来很多好处 二.Jav ...

  8. hadoop java访问_Hadoop(五)搭建Hadoop客户端与Java访问HDFS集群

    上一篇详细介绍了HDFS集群,还有操作HDFS集群的一些命令,常用的命令: hdfs dfs -ls xxx hdfs dfs -mkdir -p /xxx/xxx hdfs dfs -cat xxx ...

  9. 6 HBase java API访问HBase数据库

    HBase java API访问HBase数据库 package com.hunan.hbase_options;import org.apache.hadoop.conf.Configuration ...

最新文章

  1. hung-yi lee_p11_逻辑回归
  2. time datetime 模块
  3. 「神策 2021 数据驱动大会」即将亮相上海,再次释放前沿认知与力量
  4. [蓝桥杯][算法提高VIP]扫雷-枚举
  5. webkit事件处理
  6. 随机抽样一致算法(Random sample consensus,RANSAC)
  7. 实测解决:SpringBoot 中 Invalid character found in the request target 异常
  8. Ehcache(06)——监听器
  9. 短视频APP测试要点
  10. Cocosbuilder使用教程
  11. python异步和进程_浅谈python异步IO,同步IO,线程与进程~
  12. 关于结构光问题的总结
  13. Unity3d场景渲染出图
  14. 关于verilog中综合的过程,可综合与不可综合的理解
  15. 教您正确选择一款合适您的家用路由器
  16. 沪牌学院-沪拍拍课堂1: 估价策略
  17. 雷哥爱财,取之有道:4个月取了4000块
  18. Leetcode 387. 字符串中的第一个唯一字符
  19. 基于新浪微博的男女性择偶观数据分析
  20. Toncat环境变量的配置

热门文章

  1. 如何杀除Trojan.win32.Thsys病毒
  2. 嗜血代码软件测试,噬血代码steam版
  3. 【MariaDB】安装MariaDB,与MySQL并存
  4. matlab代码规范(自用)
  5. css垂直居中和水平居中方法总结
  6. iphone safari 小说网站 去除 弹框广告
  7. 【C语言进阶剖析】14.C语言中的单引号和双引号
  8. App Icon Gear App 图标制作工具
  9. #今日论文推荐# 速递:机器学习帮助构建人类肠道微生物群体感应网络
  10. 抖音如何直播汉字找不同小游戏