MR

news/2024/11/27 6:37:58/

一、在我们提交完MR程序之后,MR程序会先后经历map,reduce阶段,下面我们详细的来解析一下各个阶段

    1、map阶段,在这个阶段主要分如下的几个步骤read,map,collect,溢写,combine阶段

        (1)、在read阶段,maptask会调用用户自定义的RecordReader方法,在splitInput中解析出一个个的key-value对

        (2)、在map阶段,maptask会接受由前面读取来的数据,然后按照所需的逻辑对数据进行加工处理,形成新的key-value对

        (3)、在collect阶段,map在数据处理完成之后会调用OutputCollector.collect()方法把数据写入环形缓冲区中,这个环形缓冲区被分为了两部分,一半是用来存储数据的索引,一半是用来存储数据,在分区中首先是按照分区号进行排序,在分区里面在按照key进行排序,在环形缓冲区中默认的采用的是哈希分区,如果想自定义分区可以重写一个类继承partition在重新分区方法即可。

        (4)、溢写阶段,当环形缓冲区中的数据到达整个缓冲区的百分之八十的时候(环形缓冲区默认大小是100M),就会把数据写入本地的临时文件,但是为了提高性能在这儿可以调用combiner首先把数据合并之后再把数据写入零时文件,在环形缓冲区上的数据读写方法时索引存储数据和存储索引占到总大小的百分之八十多的时候,双方在结束的位置同时向开始的位置读取数据,这样循环往复。

        (5)、合并阶段,在前面产生的所有的临时文件,maptask采用轮转的方式进行合并,并且在合并之后的分区中进行排序,这样这个map就会产生一个数据的输出文件。

        (6)如下图所示

        

    2、reduce阶段主要包括如下的阶段,cpoy阶段,merge阶段,sort阶段,reduce阶段

        (1)、copy阶段主要是reducer阶段从远程的map的输出去拷贝数据到本地的内存中,同一个reducer的节点会把不同的map的输出的同一个分区拷贝到本地。

        (2)、merge阶段,在开始拷贝数据的时候。reduceTask会启动两个后台线程,合并内存中的数据和磁盘中的数据,防止使用过多的内存和磁盘。

        (3)、sort阶段,由于在reduce的数据是按照key进行聚合排序的,但是在map的输出的时候就已经进行排序,所以在这儿只需要简单的归并排序即可

        (4)、reduce阶段 ,把已经按照key聚合的数据输出给reducer按照我们的义务逻辑进行处理。

        (5)、具体如下图所示

        


http://www.ppmy.cn/news/694378.html

相关文章

MRT与MRC

发送端的预编码:MRT最大比发送 接收端的解码:MRC最大比合并(针对采用了分集技术的情况下才会使用最大比合并,合并的是多路信道,这些个信道传送的是相同的信号,只不过经历的衰落不相同) SDMA(空…

MR:二:什么是MR混合现实技术?

目录 一.目的 1.想知道:什么是MR混合现实技术? 二.参考 1. 什么是MR混合现实技术? 三.注意 四.操作:1: 一.目的 1.想知道:什么是MR混合现实技术? 二.参考 1. 什么是MR混合现实技术? http://ww…

mr 过程

默认TextInputFormat 》 fileinputformat》inputformat map partitioner compare reduce outputformat mr 之间总称为shuffle RecordReader 是 inputformat中的成员变量 中有方法read() 返回一个kv对 自定义mapper之后 到outputCollector然后环形缓冲区默认到内存100M 默…

原根-快速求解一个数的原根

1.原根定义 假设一个数g对于P来说是原根&#xff0c;那么g^i mod P的结果两两不同,且有 1<g<P, 1<i<P,那么g可以称为是P的一个原根 简单来说&#xff0c;g^i mod p ≠ g^j mod p &#xff08;p为素数&#xff09; 其中i≠j且i, j介於1至(p-1)之间 则g为p的原根。 简…

运维开发:自动化与效率的结合

引言 作为一个对技术和系统运维充满热情的工程师&#xff0c;我深知在现代云计算和软件开发环境中&#xff0c;运维的重要性和挑战。为了提高系统的稳定性、可扩展性和效率&#xff0c;我开始运用运维开发的原则和实践来加强自动化和工具化&#xff0c;以更好地管理和操作系统…

聊一聊MR过程

聊一聊MR过程 MapReduce MapReduce思想在生活中处处可见。或多或少都曾接触过这种思想。 MapReduce的思想核心是“分而治之”&#xff0c;适用于大量复杂的任务处理场景&#xff08;大规模数据处理场景&#xff09;。即使是发布过论文实现分布式计算的谷歌也只是实现了这种思…

MR之排序

1、MR 中的排序 MapTask和ReduceTask均会对数据按照key进行排序。该操作属于Hadoop的默认行为。任何应用程序中的数据均会被排序&#xff0c;而不管逻辑.上是否需要。默认排序是按照字典顺序排序&#xff0c;且实现该排序的方法是快速排序。 MapTask它会将处理的结果暂时放到…

放一些MR案例

1.partitioner分区 1.概念 1、将map输出的kv对&#xff0c;按照相同key分组&#xff0c;然后分发给不同的reducetask 默认的分发规则为&#xff1a;根据keyhashcode%reducetask 2、一般返回值从0开始&#xff0c;并且定义多少的reduce数&#xff0c;就有多少分区 2.实例 …