Weather Dataset Mining
import java.io.IOException; import java.util.Iterator; import org.apache.hadoop.fs.Path; import org.apache.hadoop.io.LongWritable; import org.apache.hadoop.io.Text; import org.apache.hadoop.mapreduce.lib.input.FileInputFormat; import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat; import org.apache.hadoop.mapreduce.lib.output.TextOutputFormat; import org.apache.hadoop.mapreduce.lib.input.TextInputFormat; import org.apache.hadoop.mapreduce.Job ; import org.apache.hadoop.mapreduce.Mapper; import org.apache.hadoop.mapreduce.Reducer; import org.apache.hadoop.conf.Configuration; public class MyMaxMin { public static class MaxTemperatureMapper extends Mapper<LongWritable, Text, Text, Text> { public static final int MISSING =9999; public void map(LongWritable arg0 , Text Value , Context context ) throws IOException, InterruptedException { String line = Value .toString(); if (!( line .length() == 0)) { Strin