WordMapperAvg.java

import java.io.IOException;

import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.Reducer;




@SuppressWarnings("unused")
public class WordMapperAvg extends Mapper<LongWritable, Text, Text,
IntWritable> {

    static enum MapCounters {
        MAP_RECORD_COUNTER
    }

    public void map(LongWritable key, Text value, Context context)
            throws IOException, InterruptedException {
        context.getCounter(MapCounters.MAP_RECORD_COUNTER).increment(1);
        String line = value.toString();


        for (String word : line.split("\\W+")) {
            if (word.length() > 0) {
            String firstletter =  Character.toString(word.charAt(0));
            String lower_first = firstletter.toLowerCase();
            Integer length = word.length();
            context.write(new Text(word), new IntWritable(length));
            context.getCounter(SumReducer2.ReducerCounters.REDUCER_RECORD_COUNTER).increment(1);

}
}
}
}