Reader_Reducer.java
a849cce6c01ams_access_migration

Reader_Reducer.java
View Options

			//package raw_reader_mapreduce;
			//
			//import java.io.IOException;
			//import java.util.Iterator;
			//
			//import org.apache.hadoop.io.IntWritable;
			//import org.apache.hadoop.io.Text;
			//import org.apache.hadoop.io.WritableComparable;
			//import org.apache.hadoop.mapred.JobConf;
			//import org.apache.hadoop.mapred.MapReduceBase;
			//import org.apache.hadoop.mapred.OutputCollector;
			//import org.apache.hadoop.mapred.Reducer;
			//import org.apache.hadoop.mapred.Reporter;
			//
			//
			//public class Reader_Reducer extends MapReduceBase implements Reducer<IntWritable, Text, EncWritable, IntWritable> {
			//
			// private String line;
			// private String[] tokens;
			// private EncWritable myrecord;
			//
			//
			//
			// @Override
			// public void configure(JobConf job) {
			// myrecord = new EncWritable();
			// }
			// @Override
			// public void reduce(IntWritable key, Iterator<Text> values, OutputCollector<EncWritable, IntWritable> output,
			// Reporter reporter) throws IOException {
			// int a = 0;
			//
			// while(values.hasNext()){
			// line = values.next().toString();
			// tokens = line.split(";");
			// myrecord.setID_p(key.get());
			//
			// myrecord.setID_m(Integer.parseInt(tokens[0]));
			//
			//
			//// System.out.println("t0: " + tokens[0]);
			//// System.out.println("t1: " + tokens[1]);
			//// System.out.println("t2: " + tokens[2]);
			//// System.out.println("t3: " + tokens[3]);
			// myrecord.setEnc_genotype1(tokens[1]);
			// myrecord.setEnc_genotype2(tokens[2]);
			// output.collect(myrecord, new IntWritable(a));
			//
			// }
			//
			//
			// }
			//
			//}