package example.loganalyzer; import java.io.IOException; import org.apache.hadoop.io.IntWritable; import org.apache.hadoop.io.LongWritable; import org.apache.hadoop.io.Text; import org.apache.hadoop.mapreduce.Mapper; public class LogAnalyzerMapper extends Mapper { public void map(LongWritable key , Text value, Context context) throws IOException,InterruptedException{ String line = value.toString(); int responseTime; String[] str = line.split(" "); responseTime = Integer.parseInt(str[str.length-1]); context.write(new Text(str[0]), new IntWritable(responseTime)); } }