Mapreduce分布式并行編程

更新時間：2022年08月05日 10:26:21 作者：王以太

這篇文章主要為大家介紹了Mapreduce分布式并行編程使用詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪

1.什么是并行計算

傳統(tǒng)并行計算：共享同一個數(shù)據(jù)，通過鎖來控制數(shù)據(jù)的讀寫，難度大，容易導(dǎo)致死鎖，拓展性差。但是是實時的，細顆粒度計算，計算密集型

Mapreduce：對機器的要求低，拓展性難，便宜，拓展性強，批處理場景，非實時，數(shù)據(jù)密集型（傻大）

map:分配工作任務(wù)給不同的人，并讓其完成工作（工作相互獨立，不互相為上下環(huán)節(jié)）

reduce：把不同的結(jié)果集合并再加上分布式

2.現(xiàn)在mapreduce能做什么？

map：映射

1.如小寫字母變成大寫字母 map

2.把年齡小于16歲的都去掉 map

3.把美元變成人民幣 y=x∗6.3y=x * 6.3y=x∗6.3 map

4.地址庫的一個翻譯：省市縣 map

5.（只要是一些處理數(shù)據(jù)相關(guān)的，都應(yīng)當是在map上）

reduce：做比較，工作整合，上下游

1.統(tǒng)計年薪最高的人（一個組）key

2.按照男女計算平均年齡（倆個組）key

3.排序 reduce

有些操作放在map、reduce里面都可以

a-------->a----->A

map--------- reduce ×

前提：盡量要減少數(shù)據(jù)的流動，reduce階段數(shù)據(jù)越少越好，能在map做就在map做掉

數(shù)據(jù)SQL:

Select name ,age,gender from people where id =3

1.project(投射）map完成

Select name ,age,gender

2.filter（過濾）map完成

id=3

3.key(匯集）

如：Select avg(age),gender from peoplemap:age,gender ---project
key:gender(F,M) //分為man和female

reduce:按照key進行匯集 F(25,38,23),M(45,23)

reduce：avg

如：Select max(age),gender from people這里和上面差不多，但是就沒有key了放在同一個地方