@@ -0,0 +1,902 @@
+import java.io.IOException;%0Aimport org.apache.commons.lang.StringUtils;%0Aimport org.apache.hadoop.io.IntWritable;%0Aimport org.apache.hadoop.io.LongWritable;%0Aimport org.apache.hadoop.io.Text;%0Aimport org.apache.hadoop.mapred.MapReduceBase;%0Aimport org.apache.hadoop.mapred.Mapper;%0Aimport org.apache.hadoop.mapred.OutputCollector;%0Aimport org.apache.hadoop.mapred.Reporter;%0A%0Apublic class AvgTempMapper extends MapReduceBase%0A%09implements Mapper%3CLongWritable, Text, Text, IntWritable%3E %7B%0A%0A%09public void map(LongWritable key, Text value,%0A%09%09%09OutputCollector%3CText, IntWritable%3E output, Reporter reporter)%0A%09%09%09throws IOException %7B%0A%09// Get the line store in array%0A%09String %5B%5D line = value.toString().split(%22,%22);%0A%09// get the extracted value for mapper i.e. day%0A%09String day = line%5B0%5D;%0A%09String temp=line%5B2%5D;%0A%09%0A%09if(StringUtils.isNumeric(temp))%0A%09%09output.collect(new Text(day), new IntWritable(Integer.parseInt(temp)));%0A%09%7D%0A%0A%7D%0A%0A

Create AvgTempMapper.java