MapReduce中,map和reduce函數遵循如下正常格式:
Mapper的基類:
Reducer的基類:
Context是上下文對象
代碼編寫依據,也就是固定寫法 input-->map--->reduce->output 以下java代碼實作此指令的功能bin/hdfs dfs jar share/hadoop/mapreduce/hadoop-mapreduce-examples-2.5.0.jar input output
map 業務處理邏輯 --------------input-------- <0,hadoop yarn> --------------處理--------- hadoop yarn -->split->hadoop,yarn -------------output------- <hadoop,1> <yarn,1>
reduce 業務處理過程 map-->shuffle-->mapreduce
mapReduce 繼承configured類, 并實作 Tool接口 tool接口類中的run方法重寫 configured 提供初始化工作。