= hadoop programming 0715 = * 整理出hadoop programming 的完全公式 || || || 輸入 key || || 輸入 value|| || 輸出 Key|| || 輸出 Value|| || || || Mapper|| < || A || , || B || , || C || , || D || , || > || || map|| ( || A || B || OutputCollector < C , D > || Reporter reporter || ) || || output|| . || collect( || c || d || ) || || || Reducer|| < || C || D || E || F || > || || reduce|| ( || C || D || OutputCollector < E , F > || Reporter reporter || ) || || output|| . || collect( || e || f || ) || || {{{ public static class Map extends MapReduceBase implements Mapper { public void map(LongWritable key, Text value, OutputCollector output, Reporter reporter) throws IOException { while (tokenizer.hasMoreTokens()) { private final static IntWritable one = new IntWritable(1); private Text word = new Text(); output.collect(word, one); }}} {{{ public static class Reduce extends MapReduceBase implements Reducer { public void reduce(Text key, Iterator values,OutputCollector output, Reporter reporter) throws IOException { int sum = 0; while (values.hasNext()) { sum += values.next().get(); } output.collect(key, new IntWritable(sum)); }}}