@@ -0,0 +1,1690 @@
+import java.io.IOException;%0A%0Aimport org.apache.hadoop.io.*;%0Aimport org.apache.hadoop.mrunit.mapreduce.MapDriver;%0Aimport org.apache.hadoop.mrunit.mapreduce.ReduceDriver;%0A%0Aimport org.junit.*;%0A%0Apublic class MaxTemperatureMapperTest %7B%0A%0A%09@Test%0A%09public void processesValidRecord() throws IOException, InterruptedException %7B%0A%09%09Text value = new Text(%220043011990999991950051518004+68750+023550FM-12+038299999V0203201N00261220001CN9999999N9-00111+99999999999%22);%0A%09%09//                               Year %5E%5E%5E%5E                                                        Temperature %5E%5E%5E%5E%5E%0A%09%09new MapDriver%3CLongWritable, Text, Text, IntWritable%3E()%0A%09%09%09.withMapper(new MaxTemperatureMapper())%0A%09%09%09.withInputValue(value)%0A%09%09%09.withOutput(new Text(%221950%22), new IntWritable(-11))%0A%09%09%09.runTest();%0A%09%0A%09@Test%0A%09public void ignoreMissingTemperatureRecord() throws IOException, InterruptedException %7B%0A%09%09Text value = new Text(%220043011990999991950051518004+68750+023550FM-12+038299999V0203201N00261220001CN9999999N9+99991+99999999999%22);%0A%09%09//                               Year %5E%5E%5E%5E                                                        Temperature %5E%5E%5E%5E%5E%0A%09%09new MapDriver%3CLongWritable, Text, Text, IntWritable%3E()%0A%09%09%09.withMapper(new MaxTemperatureMapper())%0A%09%09%09.withInputValue(value)%0A%09%09%09.runTest();%0A%09%7D%0A%7D%0A%0Apublic class MaxTemperatureReducerTest %7B%0A%0A%09@Test%0A%09public void returnsMaximumIntegerInValues() throws IOException, InterruptedException %7B%0A%09%09new ReducerDriver%3CText, IntWritable, Text, IntWritable%3E()%0A%09%09%09.withReducer(new MaxTemperatureReducer())%0A%09%09%09.withInputKey(new Text(%221950%22))%0A%09%09%09.withInputValues(Arrays.asList(new IntWritable(10), new IntWritable(5)))%0A%09%09%09.withOutput(new Text(%221950%22), new Intwritable(10))%0A%09%09%09.runTest();%0A%09%7D%0A%7D%0A

Create MaxTemperatureTest.java