package edu.calstatela.hipic.hadoop.util;

// cc MaxTemperatureMapper Mapper for maximum temperature example
// vv MaxTemperatureMapper
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.mapred.MapReduceBase;
import org.apache.hadoop.mapred.Mapper;
import org.apache.hadoop.mapred.OutputCollector;
import org.apache.hadoop.mapred.Reporter;

public class MaxTemperatureMapper extends MapReduceBase
  implements Mapper<LongWritable, Text, Text, IntWritable> {

  private static final int MISSING = 9999;
  
  public void map(LongWritable key, Text value,
      OutputCollector<Text, IntWritable> output, Reporter reporter)
      throws IOException {
    
    String line = value.toString();
    String year = line.substring(15, 19);
    int airTemperature=0;
    if (line.length()>92 && line.charAt(87) == '+') { // parseInt doesn't like leading plus signs
      airTemperature = Integer.parseInt(line.substring(88, 92));
    } else {
    	if (line.length()>92)airTemperature = Integer.parseInt(line.substring(87, 92));
    }
    if (line.length()>93){
    		String quality = line.substring(92, 93);
		    if (airTemperature != MISSING && quality.matches("[01459]")) {
		      output.collect(new Text(year), new IntWritable(airTemperature));
		    }
  	}
  }
}
// ^^ MaxTemperatureMapper