@@ -0,0 +1,944 @@
+import java.io.IOException;%0A%0Aimport org.apache.hadoop.io.IntWritable;%0Aimport org.apache.hadoop.io.LongWritable;%0Aimport org.apache.hadoop.io.Text;%0Aimport org.apache.mapreduce.Mapper;%0A%0Apublic class MaxTemeratureMapper extends Mapper%3CLongWritable, Text, Text, IntWritable %7B%0A%0A%09private static final int MISSING = 9999;%0A%09%0A%09@Override%0A%09public void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException %7B%0A%09%0A%09%09String line = value.toString();%0A%09%09String year = line.substring(15, 19);%0A%09%09int airTemperature;%0A%09%09if (line.charAt(87) == '+') %7B // parseInt doesn't like leading plus signs before Java 7%0A%09%09%09airTemperature = Integer.parseInt(line.substring(88, 92));%0A%09%09%7D else %7B%0A%09%09%09airTemperature = Integer.parseInt(line.substring(87, 92));%0A%09%09%7D%0A%09%09String quality = line.substring(92,93);%0A%09%09if (airTemperature != MISSING && quality.matches(%22%5B01459%5D%22)) %7B%0A%09%09%09context.write(new Text(year), new IntWritable(airTemperature));%0A%09%09%7D%0A%09%7D%0A%7D%0A

Create MaxTemperatureMapper.java