Added CityYearRecord

Author: pabloazar

org/hackreduce/examples/Stage2Reducer.java

@@ -0,0 +1,36 @@
+package org.hackreduce.examples;
+
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.conf.Configured;
+import org.apache.hadoop.fs.FileSystem;
+import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.io.NullWritable;
+import org.apache.hadoop.io.Text;
+import org.apache.hadoop.mapreduce.Job;
+import org.apache.hadoop.mapreduce.Reducer;
+import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
+import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
+import org.apache.hadoop.util.Tool;
+import org.apache.hadoop.util.ToolRunner;
+import org.hackreduce.mappers.BixiMapper;
+import org.hackreduce.models.BixiRecord;
+
+/**
+ *
+ */
+public class Stage2Reducer extends Reducer<Text, CityYearRecord, Text,CityYearRecord> {
+ationReduce
+	 
+	 
+	   public void reduce(Key key, Iterable<CityYearRecord> values, 
+	                      Context context) throws IOException {
+	     int sum = 0;
+	     for (CityYearRecord val : values) {
+	       sum += val.getCount();
+	     }
+	     String year = key.
+	     CityYearRecord result = new CityYearRecord(,,sum) ;
+	     context.collect(year, result);
+	   }
+	 }
+}

src/main/java/org/hackreduce/models/CityYearRecord.java

@@ -0,0 +1,40 @@
+package org.hackreduce.models;
+
+public class CityYearRecord {
+	private String cityName;
+	private String year;
+	private int count;
+	
+	public CityYearRecord(String cityName, String year, int count){
+		this.cityName = cityName;
+		this.year = year;
+		this.count = count;
+	}
+	
+	public String getCityName(){
+		return cityName;
+	}
+	
+	public String getYear(){
+		return year;
+	
+	}
+	
+	public int getCount(){
+		return count;
+	}
+	
+	public void setCityRecord(String cityName){
+		this.cityName = cityName;
+	}
+	
+	public void setCount(int count){
+		this.count = count;
+	}
+	
+	public void setYear(String year){
+		this.year = year;
+	}
+	
+	
+}