liu6182169 发表于 2015-11-17 12:09
整段代码是这样子的：
        public static class IntSumReducer extends
                        Reducer {

   添加下面红字部分
public static class IntSumReducer extends
                        Reducer<Text, IntWritable, Text, IntWritable> {
                private IntWritable result = new IntWritable();

                public void reduce(Text key, Iterable<IntWritable > values, Context context)
                                throws IOException, InterruptedException {
                        int sum = 0;
                        for (IntWritable val : values) {
                                sum += val.get();
                        }
                        sum=100;
                        result.set(sum);
                        context.write(key, result);
                }
        }

整段代码是这样子的：
        public static class IntSumReducer extends
                        Reducer<Text, IntWritable, Text, IntWritable> {
                private IntWritable result = new IntWritable();

                public void reduce(Text key, Iterable values, Context context)
                                throws IOException, InterruptedException {
                        int sum = 0;
                        for (IntWritable val : values) {
                                sum += val.get();
                        }
                        sum=100;
                        result.set(sum);
                        context.write(key, result);
                }
        }