Hadoop是一个用于构建分布式应用程序的框架。Hadoop框架给应用程序透明的提供了一组稳定和可靠的接口。这项技术的实现得易于映射/ 归约编程范式。在这个范式里,一个应用程序被分割成为许多的小的任务块。每一个这样的任务块被集群中的任意一个节点的计算机执行或重新执行。此外,这种范 式还提供了一种分布式的文件系统,这种文件系统用来存储数据于集群中相互间具有高带宽的计算机上。映射/归约和分布式文件系统都被设计成为容错的结构。也 就是说,当集群中某个节点发生了故障整个文件系统或者映射/归约操作仍然能够有效的运作。
Hadoop起初是作为Nutch项目的基础结构来开发的。有关Nutch得更具体的信息可以访问Apache关于Nutch开源项目的官方网站。Hadoop和Nutch都隶属于Lucene Apache项目。Hadoop的映射/归约(Map/Reduce)设计模型和执行框架:
映射/归约是一种编程范式最早在Lisp编程语言中得已实现,这种范式将一个大型的分布式计算看作是一系列建立在 键/值映射数据集上的分布式操作。Hadoop的映射/规约框架利用一个集群中的计算机执行用户定义的映射/归约任务。一个映射/规约操作分为两个阶段: 映射阶段和规约阶段。用户通常是把一个键值对应的数据集作为计算的输入提供给系统。在映射阶段,框架将用户输入的数据分割成很多片断(fragments)并把每一个数据片断分配一个映射任务。系统常常将很多这样的映射任务分 配给一个集群中多个运行了该框架的计算机。每一个映射操作包括消耗掉数据片断中的键值对并且产生一个中间态的键值对应集合。例如对于每一个输入的键值对 (K,V),映射操作调用用户定义的映射函数将(K,V)对转化成为一个不同的键值对(K’,V’)接着,系统结构将这些中间态的数据集按照键的值进行排序并生成一个新的(K’,V’*)元组(tuples)。这样所有对应同一个键不同值的数据便会被放到一起。同时系统也将这些元组分隔成为很多片断,这些片段的数目等同于归约任务的数目。在归约的阶段,每一个归约操作消耗掉分配给它的(K’,V’*)片断。对于每一个这样的元组,归约操作会调用用户定义的归约函数用来将这些片断 转化成为用户需要的键值对(K,V)进行输出。和映射操作类似,系统将这许许多多的归约操作分配给集群计算机并且负责将映射操作中所产生的中间态数据集传 输给相应的归约操作。在各个阶段时候的操作都是作为一种容错的风格来执行的。如果某个节点在执行操作中发生故障。其正在执行的任务将重新分配给其他的节点。多个映射归约任务的同时执行保证了良好的装载平衡,同时,也确保发生故障的机器在重新启动以后能够很快的被重新分配任务。Hadoop映射/归约的架构:
Hadoop映射/归约框架是一个主/从(master/slave)架构.它由一个主服务器(Jobtracker)和若干从服务器(tasktracker)组成。主服务器是用户与系统打交道的关键。用户将自定义的
映射/归约操作提交给主服务器。主服务器将操作放入作业队列中并按照先到先服务的原则对队列中的任务进行处理。主服务器用来将映射或者归约操作分配给不同的从服务器。从服务器在主服务器的控制下执行操作,同时,不同的从服务器间在映射和归约阶段也进行着数据传输Hadoop DFS
Hadoop的分布式文件系统(HDFS)被设计用来在集群计算机间存储大型 数据文件。这个设计来源于Google文件系统(GFS)。Hadoop分布式文件系统将每一个文件作为一组数据块进行存储,一个文件中除了最后一个数据 块的所有数据块都具有相同的大小。作为容错处理,这些数据块被复制成为了很多份。每一个文件的数据块大小和复制的份数是可以被管理员配置的。另外,值得注 意的是,HDFS中的文件都是只写一次并且每一个时间点严格的只允许一个线程执行写操作。HDFS构架:类似于Hadoop的映射规约(Map/Reduce), HDFS也遵循 master/Slave的架构。一个HDFS装置包括了一个控制服务器用来管理文件系统的命名空间和管理客户服务器对文件的访问,我们把这样的节点也叫 做命名节点(Namenode)。此外,在这样一个装置中还包括了一系列的数据节点(Datanode),每一个数据节点代表一个运行了HDFS文件系统 存储结构的机群计算机。命名节点通过一个RPC的结构对文件系统进行类似于文件或目录的打开,关闭,重命名之类的操作。同时,命名节点也负责决定将数据块 映射(Map)到相应的数据节点上。而数据节点则负责向文件系统的用户提供对文件的读写操作。数据节点也可以在命名节点的控制下对数据块进行创建,删除或 者复制的操作。
Lucene-Hadoop, GFS中Map/Reduce的简单实现
时间: 2024-10-22 12:32:00
Lucene-Hadoop, GFS中Map/Reduce的简单实现的相关文章
hadoop教程(八) map/reduce的读取和写入
write/read 参考<hadoop权威指南>书的63和66页 读取流程 写入流程 查看本栏目更多精彩内容:http://www.bianceng.cnhttp://www.bianceng.cn/webkf/tools/
基于Hadoop的Map reduce编程(一)
翻译的一篇国外的关于hadoop mapreduce的文章,文章比较长,先翻译第一部分吧 翻译者:pconlin900 博客:http://pconline900.javaeye.com Hadoop是apache的一个开源的map-reduce框架,MapReduce是一个并行计算模型,用来处理海量数据.模型思想来源于google的Jeffrey Dean 和 Sanjay Ghemawat,包括map() reduce()两个主要的功能. 这是一个很简单的类似于Hadoop的MapReduc
Hadoop Map/Reduce教程
目的 这篇教程从用户的角度出发,全面地介绍了Hadoop Map/Reduce框架的各个方面. 先决条件 请先确认Hadoop被正确安装.配置和正常运行中.更多信息见: Hadoop快速入门对初次使用者. Hadoop集群搭建对大规模分布式集群. 概述 Hadoop Map/Reduce是一个使用简易的软件框架,基于它写出来的应用程序能够运行在由上千个商用机器组成的大型集群上,并以一种可靠容错的方式并行处理上T级别的数据集. 一个Map/Reduce 作业(job) 通常会把输入的数据集切分为若
Ruby中的类Google Map/Reduce框架Skynet介绍_ruby专题
Skynet是一个很响亮的名字,因为它是阿诺施瓦辛格主演的经典系列电影<终结者>里面的统治人类的超级计算机网络.不过本文的Skynet没这么恐怖,它是一个ruby版本的Google Map/Reduce框架的名字而已. Google的Map/Reduce框架实在太有名气了,他可以把一个任务切分为很多份,交给n台计算机并行执行,返回的结果再并行的归并,最后得到运算的结果.据说Google一个搜索结果会Map到7000台服务器并行执行,这么多么可怕的分布式运算能力阿!有了Map/Reduce,程序
hadoop中map处理多行数据,可以满足用于算法模型的输入。
问题描述 hadoop中map处理多行数据,可以满足用于算法模型的输入. 在分布式平台做算法研究,遇到一个map处理文件是以行为单位.怎么使map可以 读取多行数据然后可以在map中进行算法模型的训练. 以下是我的尝试: 1:NLineInputFormat 不行,还是单行输出数据. 2:重写 InputFormat函数. 数据集没有具体的切分标志,只能说一个map处理 100或200行数据.没有类似 {} " " -- 的切分标志. 解决方案 你重写函数后也总要有一个规则来定义你的m
Python中的高级函数map/reduce使用实例_python
Python内建了map()和reduce()函数. 如果你读过Google的那篇大名鼎鼎的论文"MapReduce: Simplified Data Processing on Large Clusters",你就能大概明白map/reduce的概念. 我们先看map.map()函数接收两个参数,一个是函数,一个是序列,map将传入的函数依次作用到序列的每个元素,并把结果作为新的list返回. 举例说明,比如我们有一个函数f(x)=x2,要把这个函数作用在一个list [1, 2,
js中遍历Map对象的简单实例_javascript技巧
实例如下: console.log(jsonData);//火狐控制台打印输出: Object { fileNumber="文件编号", fileName="文件名称"} for(var key in jsonData) console.log("属性:" + key + ",值:"+ jsonData[key]); } 打印输出: 属性:fileNumber, 值:文件编号 属性:fileName, 值:文件名称 以上这篇j
Hadoop 少量map/reduce任务执行慢问题
最近在做报表统计,跑hadoop任务. 之前也跑过map/reduce但是数据量不大,遇到某些map/reduce执行时间特别长的问题. 执行时间长有几种可能性: 1. 单个map/reduce任务处理的任务大. 需要注意每个任务的数据处理量大小不至于偏差太大.可以切割部分大文件. 2. map数量过多, reduce拉取各方数据慢 这种情况,可以在中间加一轮map过程A. 即map -> mapA - > reduce,来减少reduce拉取数据的源头的个数. 3.
基于AHP的Reduce Task预设配比在Hadoop调度中的应用
基于AHP的Reduce Task预设配比在Hadoop调度中的应用 周莲英 吴淑跃 现有的研究工作都是从宏观上进行调度的优化,而在微观上,如对不同MapReduce应用程序的参数设置配比等,没有一个详细的研究 针对这一研究空白,本文提出将一种基于AHP的Reduce Task启动执行方案,从微观上对具体的MapReduce应用程序提供调度优化,以达到提高资源利用率的目的. 基于AHP的Reduce Task预设配比在Hadoop调度中的应用