Update Pulmonary_state

kiran0541 · Oct 21, 2015 · 0b08843 · 0b08843
1 parent 2f69d78
commit 0b08843
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/Pulmonary_state b/Pulmonary_state
@@ -53,8 +53,8 @@ state.toString().equalsIgnoreCase("tx")){
                 Job job = new Job(conf, "wordcount");
            job.setJarByClass(Pulomonary_states.class);
 
-           job.setMapOutputKeyClass(Text.class);
-           job.setMapOutputValueClass(Text.class);
+           job.setMapOutputKeyClass(Text.class);  //in case output for mapper is different from..
+           job.setMapOutputValueClass(Text.class); // ..the input of reducer 
        job.setOutputKeyClass(Text.class);
        job.setOutputValueClass(IntWritable.class);