MapReduce的简单案例

mapper

mapK、VcontextmapmapsplitStringTokeizer

,Whilecontext

要书写一个程序主入口类,将程序打包发给JobTracker(移动计算而不是移动数据)

xxx.jarnamenode Hadoop/binhadoop

#。hadoop/hadoop ()

#。/hadoop  jar ,,路径/xxx.jar  ww.cola。JobRun

- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -

KV mapmapKV

地图

shuffK KeyValue

A: B C D E ,//值

B: G

C: F

减少组

- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -

,

,

W=TF * Log (N/DF),,特遣部队:

DF:, 41 N

,

()

,,,,,,,,id ,,,1:2:,3:…。

之后我会专门写一篇博客

MapReduce的简单案例