HDFS下载数据机制的底层分析

Hadoop中的RPC(Remote Procedure Call)框架

hadoop中结点间的通信采用的是RPC。

RPC框架的实现机制图解:

从hdfs下载数据的源码分析

在自行在客户端编写download方法的时候,如果不使用封装好的方法,较为底层的写法是:

    Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://node01:9000/");
FileSystem fs = FileSystem.get(new URI("hdfs://node01:9000/"), conf, "thousfeet");
FSDataInputStream is = fs.open(new Path("/test.txt"));
FileOutputStream os = new FileOutputStream("c:/xxx.txt");
IOUtils.copy(is,os);

跟踪查看在HDFS源码的内部实现:

getFileSystem

关键代码的流程图解:

inputstream

关键代码:

最新文章

  1. u盘安装系统教程详解
  2. PDFobject插件使用,PDF在线查看插件
  3. 11月7日上午PHP会话控制(session和cookie)、跨页面传值
  4. 软件测试第六周学习笔记之“Win8 APP应用程序的白盒测试”
  5. Makefile变量
  6. parted在2T以上硬盘上分区操作
  7. poj 2488
  8. 腾讯云TDSQL审计原理揭秘
  9. 使用Reveal查看任意App的技巧
  10. C# 调用C++动态链接库
  11. json 對象的序列化
  12. ***mysql中查询今天、昨天、上个月sql语句
  13. 深入理解linux网络技术内幕读书笔记(七)--组件初始化的内核基础架构
  14. Maven 添加Jetty
  15. 基于hi-nginx的web开发(python篇)——表单处理和文件上传
  16. OV2685翻转问题
  17. 微信小程序开发工具中快捷键
  18. 20172328 2018-2019《Java软件结构与数据结构》第七周学习总结
  19. SKCTF Writeup
  20. RISC-V踩坑记----__builtin_clz((x)库函数的应用

热门文章

  1. [转]SQL Server如何启用xp_cmdshell组件
  2. mvc中的action验证登录(ActionFilterAttribute)
  3. wcf读写cookie
  4. 使用iTextSharp 解析html生成pdf,xmlworker不支持中文的解决办法
  5. SpringMVC 面试题
  6. SpringBoot(二) Core Features: SpringApplication
  7. [LeetCode] Next Permutation(一种巧妙的解题方法)
  8. Implementation:UnionFindSet 并查集
  9. 【PyQt5 学习记录】009:批量创建组件并查找
  10. angular2.0入门---webStorm创建angular CLI项目