Hadoop中的MapReduce框架原理、切片源码断点在哪断并且介绍相关源码、FileInputFormat切片源码解析、总结,那些可以证明你看过切片的源码

简介: Hadoop中的MapReduce框架原理、切片源码断点在哪断并且介绍相关源码、FileInputFormat切片源码解析、总结,那些可以证明你看过切片的源码

@[toc]

13.MapReduce框架原理

13.1InputFormat数据输入

13.1.3FileInputFormat切片源码解析

13.1.3.1切片源码断点在哪断并且介绍相关源码:

断点在https://blog.csdn.net/Redamancy06/article/details/126501627?spm=1001.2014.3001.5501
这篇文章写了一部分了,可以先跟着这篇文章做,然后再看这篇文件就好理解了。

在这里插入图片描述一直运行到这一步然后强制进入。
在这里插入图片描述在这个位置打上断点,然后再断点处强行进入

在这里插入图片描述进去后在这两个地方打上断点

在这里插入图片描述然后进入这个断点
在这里插入图片描述就到FileInputFormat类里面了

在这里插入图片描述然后一直往上翻到最上面,点这个按下f4,就可以出现继承关系(type hierarchy)

在这里插入图片描述

  • 红色框住的是最常用的

TextInputFormat是默认的按行切
CombineTextInputFormat把多个小文件放到一起统一的进行切割

  • 还有两个不经常用的

NLineInputFormat按行进行切割
KeyValueTextInputFormat

在这里插入图片描述
我是设置过的,参考的尚硅谷的java课程,有兴趣的可以看下我之前的博客,或者你在设置里面全部快捷键里搜一下type hierarchy
在这里插入图片描述就可以知道你的快捷键是什么了

https://blog.csdn.net/Redamancy06/article/details/126134561

在这里插入图片描述这里minSize获取的是1,1是怎么来的,可以看getFormatMinSplitSize这个和getMinSplitSize方法

在这里插入图片描述getFormatMinSplitSize方法他是返回的是1,

在这里插入图片描述他这个值是由mapreduce.input.fileinputformat.split.minsize这个值来决定

这个参数去mapred-default.xml里面找

在这里插入图片描述

<property>
  <name>mapreduce.input.fileinputformat.split.minsize</name>
  <value>0</value>
  <description>The minimum size chunk that map input should be split
  into.  Note that some file formats may have minimum split sizes that
  take priority over this setting.</description>
</property>

这里的值默认是0
所以minSize的值取1

在这里插入图片描述
maxSize没有获取到,是为什么呢,进入getMaxSplitSize方法里面看看

在这里插入图片描述他的值是由mapreduce.input.fileinputformat.split.maxsize这个值决定
在这里插入图片描述在mapred-default.xml里面mapreduce.input.fileinputformat.split.maxsize是找不到的,如果找不到,则会返回long的最大值,

在这里插入图片描述这里开始循环变量输入的个数,这里可以说明是一个文件一个文件的切片

在这里插入图片描述这里可以看出来文件地址,和文件大小

在这里插入图片描述

在这里插入图片描述

然后继续往下走到这里,isSplitable是检查是否支持切片,如果是压缩文件就不支持切片

在这里插入图片描述
然后再往下走到这里,blockSize是块的大小为32m,因为是在本地,所以他是32m

在这里插入图片描述然后再往下走,splitSize是切片大小,他也是32m,是怎么来的,进入computeSplitSize方法看看
在这里插入图片描述
因为minSize为1,maxSize为long 的最大值,blockSize是32,所以切片的大小与minSize和maxSize有关,可以通过调整这两个的值来改变切片的大小

在这里插入图片描述
如果文件大小除以切片大小大于1.1则切成两片,如果小于1.1则按一片来处理

在这里插入图片描述
这行代码就是将切片信息存在本地
在这里插入图片描述
然后后面就是job提交源码的过程,有兴趣的可以看我之前写的博客https://blog.csdn.net/Redamancy06/article/details/126501627?spm=1001.2014.3001.5501

13.1.3.2切片源码详解

在这里插入图片描述
在这里插入图片描述双shift打开查找文件,然后输入InputFormat
在这里插入图片描述
然后按f4打开这个进入FileInputFormat
在这里插入图片描述
然后ctrl+f3查看对应的方法

最主要关心的是getSplits这个方法

在这里插入图片描述
这个方法里有切片是怎么切的

13.1.3.3总结,那些可以证明你看过切片的源码

在这里插入图片描述他的切片原则是按照每一个文件单独切片

在这里插入图片描述还有这个,他的值取决于块大小,minSize,maxSize,但是块大小是不能改变的,因为他是实实在在存在物理地址的数据,因此块是不能改变的,但是minSize,和maxSize是可以改变的,可以通过改变这两个值来改变切片大小

在这里插入图片描述然后就是这个1.1倍的事

相关文章
|
分布式计算 资源调度 Hadoop
大数据-80 Spark 简要概述 系统架构 部署模式 与Hadoop MapReduce对比
大数据-80 Spark 简要概述 系统架构 部署模式 与Hadoop MapReduce对比
421 2
|
数据采集 分布式计算 Hadoop
使用Hadoop MapReduce进行大规模数据爬取
使用Hadoop MapReduce进行大规模数据爬取
|
自动驾驶 物联网 5G
|
Go
Go语言切片深入解析:按值传递的奥秘
【10月更文挑战第27天】
211 0
|
SQL 分布式计算 关系型数据库
Hadoop-24 Sqoop迁移 MySQL到Hive 与 Hive到MySQL SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
Hadoop-24 Sqoop迁移 MySQL到Hive 与 Hive到MySQL SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
400 0
|
SQL 分布式计算 关系型数据库
Hadoop-23 Sqoop 数据MySQL到HDFS(部分) SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
Hadoop-23 Sqoop 数据MySQL到HDFS(部分) SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
249 0
|
算法 测试技术 C语言
深入理解HTTP/2:nghttp2库源码解析及客户端实现示例
通过解析nghttp2库的源码和实现一个简单的HTTP/2客户端示例,本文详细介绍了HTTP/2的关键特性和nghttp2的核心实现。了解这些内容可以帮助开发者更好地理解HTTP/2协议,提高Web应用的性能和用户体验。对于实际开发中的应用,可以根据需要进一步优化和扩展代码,以满足具体需求。
1216 29
|
前端开发 数据安全/隐私保护 CDN
二次元聚合短视频解析去水印系统源码
二次元聚合短视频解析去水印系统源码
507 4
|
JavaScript 算法 前端开发
JS数组操作方法全景图,全网最全构建完整知识网络!js数组操作方法全集(实现筛选转换、随机排序洗牌算法、复杂数据处理统计等情景详解,附大量源码和易错点解析)
这些方法提供了对数组的全面操作,包括搜索、遍历、转换和聚合等。通过分为原地操作方法、非原地操作方法和其他方法便于您理解和记忆,并熟悉他们各自的使用方法与使用范围。详细的案例与进阶使用,方便您理解数组操作的底层原理。链式调用的几个案例,让您玩转数组操作。 只有锻炼思维才能可持续地解决问题,只有思维才是真正值得学习和分享的核心要素。如果这篇博客能给您带来一点帮助,麻烦您点个赞支持一下,还可以收藏起来以备不时之需,有疑问和错误欢迎在评论区指出~
|
移动开发 前端开发 JavaScript
从入门到精通:H5游戏源码开发技术全解析与未来趋势洞察
H5游戏凭借其跨平台、易传播和开发成本低的优势,近年来发展迅猛。接下来,让我们深入了解 H5 游戏源码开发的技术教程以及未来的发展趋势。

相关实验场景

更多

推荐镜像

更多
  • DNS