建站
咨詢
售后
建站咨詢
新聞中心
1、什么是MapReduce
1. Hadoop MapReduce 是一個 分布式計(jì)算框架，用于輕松編寫分布式應(yīng)用程序，這些應(yīng)用程序以可靠，容錯的方式并行處理大型硬件集群（數(shù)千個節(jié)點(diǎn)）上的大量數(shù)據(jù)（多TB數(shù)據(jù)集）
2. MapReduce 是一種面向海量數(shù)據(jù)處理的一種指導(dǎo)思想，也是一種用于對大規(guī)模數(shù)據(jù)進(jìn)行分布式計(jì)算的編程模型。
2、Map Reduce的優(yōu)缺點(diǎn)
2.1 優(yōu)點(diǎn)
? MapReduce易于編程： 它簡單的實(shí)現(xiàn)一些接口，就可以完成一個分布式程序
? 良好的擴(kuò)展性： 當(dāng)你的計(jì)算資源不能得到滿足的時候，你可以通過簡單的增加機(jī)器來擴(kuò)展它的計(jì)算能力。
? 高容錯性： MapReduce設(shè)計(jì)的初衷就是使程序能夠部署在廉價(jià)的PC機(jī)器上，這就要求它具有很高的容錯性。比如其中一臺機(jī)器掛了，它可以把上面的計(jì)算任務(wù)轉(zhuǎn)移到另外一個節(jié)點(diǎn)上運(yùn)行，不至于這個任務(wù)運(yùn)行失敗，而且這個過程不需要人工參與，而完全是由Hadoop內(nèi)部完成的。
? 適合PB級以上海量數(shù)據(jù)的離線處理： 可以實(shí)現(xiàn)上千臺服務(wù)器集群并發(fā)工作，提供數(shù)據(jù)處理能力。
2.2 缺點(diǎn)
? 實(shí)時計(jì)算性能差： MapReduce 主要應(yīng)用于離線作業(yè)，無法做到秒級或者是亞秒級別的數(shù)據(jù)響應(yīng)。
? 不能進(jìn)行流式計(jì)算： 流式計(jì)算的輸入數(shù)據(jù)是動態(tài)的，而MapReduce的輸入數(shù)據(jù)集是靜態(tài)的，不能動態(tài)變化。這是因?yàn)镸apReduce自身的設(shè)計(jì)特點(diǎn)決定了數(shù)據(jù)源必須是靜態(tài)的。
? 不擅長DAG（有向無環(huán)圖）計(jì)算 多個應(yīng)用程序存在依賴關(guān)系，后一個應(yīng)用程序的輸入為前一個的輸出。在這種情況下，MapReduce并不是不能做，而是使用后，每個MapReduce作業(yè)的輸出結(jié)果都會寫入到磁盤，會造成大量的磁盤IO，導(dǎo)致性能非常的低下。
3、 MapReduce進(jìn)程
一個完整的MapReduce程序在分布式運(yùn)行時有三類實(shí)例進(jìn)程： （1）MrAppMaster：負(fù)責(zé)整個程序的過程調(diào)度及狀態(tài)協(xié)調(diào)。 （2）MapTask：負(fù)責(zé)Map階段的整個數(shù)據(jù)處理流程。 （3）ReduceTask：負(fù)責(zé)Reduce階段的整個數(shù)據(jù)處理流程。
4、MapReduce編程規(guī)范
? 用戶編寫的程序代碼分成三個部分： Mapper、Reducer和Driver(客戶端提交作業(yè)驅(qū)動程序)
? 用戶自定義的Mapper和Reducer都要繼承各自的父類。
Mapper階段：
1. 用戶自定義的Mapper要繼承自己的父類
2. Mapper的輸入數(shù)據(jù)是KV對的形式（KV的類型可自定義）
3. Mapper中的業(yè)務(wù)邏輯寫在map()方法中
4. Mapper的輸出數(shù)據(jù)是KV對的形式（KV的類型可自定義）
5. map()方法（MapTask進(jìn)程）對每一個
Reducer階段：
1. 用戶自定義的Reducer要繼承自己的父類
2. Reducer的輸入數(shù)據(jù)類型對應(yīng)Mapper的輸出數(shù)據(jù)類型，也是KV
3. Reducer的業(yè)務(wù)邏輯寫在reduce()方法中
4. ReduceTask進(jìn)程對每一組相同k的
Driver： 描述的是提交Job對象需要的各種必要的信息。
MapReduce內(nèi)置了很多默認(rèn)屬性，比如： 排序（key的字典序）、分組(reduce階段key相同的為一組，一組調(diào)用一次reduce處理)等，這些都和數(shù)據(jù)的K有關(guān)，所以說kv的類型數(shù)據(jù)確定是及其重要的。
5、常用數(shù)據(jù)序列化類型
|
Java類型 |
Hadoop Writable類型 |
|
Boolean |
BooleanWritable |
|
Byte |
ByteWritable |
|
Int |
IntWritable |
|
Float |
FloatWritable |
|
Long |
LongWritable |
|
Double |
DoubleWritable |
|
String |
Text |
|
Map |
MapWritable |
|
Array |
ArrayWritable |
|
Null |
NullWritable |
名稱欄目：MapReduce的基礎(chǔ)知識
標(biāo)題網(wǎng)址：http://m.5511xx.com/article/ccspiso.html
