MapTask 工作机制.| 学习笔记

简介: 快速学习 MapTask 工作机制.

开发者学堂课程【Hadoop 分布式计算框架 MapReduc:MapReduce 工作机制学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/94/detail/1536


MapTask 工作机制.

 

MapTask 工作机制如图4-12所示。

图片1幸运.png 

图4-12

接下来让我们进行 Maptask 工作机制和 Reudce 工作机制的学习,而两者相结合就是 MapReduce 详细工作流程,但在面试官询问时候的角度不一样,或是说法不同,我们应该有所了解。

主要内容

而 Mpatask 工作中主要分为以下五个阶段

图片1幸运2.png

首先获得待处理的信息,再处理切片信息,提交切片、架包、插包信息到集群,然后集群再启用相应的 MrAppMaster,启动之后,就开启相应的 Map Task。

而开启了 Map Task 之后才是真正的 Map Task 工作机制的开始,首先用RecorderReader 去读一行行的数据就是 Read 阶段

 

 

图片1幸运3.png

而读完之后返回相应的 k.v 数据,并把数据写入到 Mapper 之中去则是 Map 阶段

图片1钱钱钱.png

 

往出再写数据,到了环形缓冲区块的时候,就对应着Collect(收集)阶段,包括之后的分区、排序都属于收集阶段。

排序之后往磁盘中进行溢写就是溢写阶段,且溢写可能会有多个,溢写之后对其文件再进行合并就是 Combine 阶段,

而有些面试官就喜好于询问溢写阶段是什么?

Combine 阶段是什么?

答案就同我们图中所表示的一样。而 Collect 阶段做了哪些操作,

我们也要知道是分区和排序。而对于什么排序?默认是什么排序?

采用的手段是什么?

我们也要明白是对于 key,采用了外排等等。

图片1幸运6.png

以上就是所有 MapTask 的工作机制所有内容

相关文章
|
3月前
|
调度
Netty运行原理问题之事件调度工作的问题如何解决
Netty运行原理问题之事件调度工作的问题如何解决
|
存储
15 DATANODE的工作机制
15 DATANODE的工作机制
97 0
|
6月前
|
缓存 分布式计算 搜索推荐
MapReduce【MapTask和ReduceTask的工作机制】
MapReduce【MapTask和ReduceTask的工作机制】
|
存储 数据管理
14 NAMENODE的工作机制
14 NAMENODE的工作机制
73 0
|
分布式计算
MapTask、Shuffle、ReduceTask工作机制
MapTask、Shuffle、ReduceTask工作机制
63 0
|
分布式计算 大数据 调度
Spark 原理_总体介绍_集群环境 | 学习笔记
快速学习 Spark 原理_总体介绍_集群环境
Spark 原理_总体介绍_集群环境 | 学习笔记
|
存储 缓存 块存储
HDFS工作机制和读写流程
HDFS工作机制和读写流程
172 0
HDFS工作机制和读写流程
|
存储 XML 缓存
Hadoop中的MapReduce框架原理、Job提交流程源码断点在哪断并且介绍相关源码、切片与MapTask并行度决定机制、MapTask并行度决定机制
Hadoop中的MapReduce框架原理、Job提交流程源码断点在哪断并且介绍相关源码、切片与MapTask并行度决定机制、MapTask并行度决定机制
Hadoop中的MapReduce框架原理、Job提交流程源码断点在哪断并且介绍相关源码、切片与MapTask并行度决定机制、MapTask并行度决定机制
|
存储 机器学习/深度学习 分布式计算
Hadoop中的DataNode、工作机制、数据完整性、掉线时限参数设置
Hadoop中的DataNode、工作机制、数据完整性、掉线时限参数设置
Hadoop中的DataNode、工作机制、数据完整性、掉线时限参数设置
|
存储 分布式计算 Hadoop
Hadoop的namenode的管理机制,工作机制和datanode的工作原理
HDFS前言:   1) 设计思想     分而治之:将大文件、大批量文件,分布式存放在大量服务器上,以便于采取分而治之的方式对海量数据进行运算分析;   2)在大数据系统中作用:     为各类分布式运算框架(如:mapreduce,spark,tez,……)提供数据存储服务   3...
1945 0

相关实验场景

更多