Advertisement
Guest User

Untitled

a guest
May 19th, 2019
95
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.63 KB | None | 0 0
  1. import java.io.IOException;
  2. import java.util.Iterator;
  3.  
  4. import org.apache.hadoop.io.IntWritable;
  5. import org.apache.hadoop.io.Text;
  6. import org.apache.hadoop.mapreduce.Reducer;
  7.  
  8. public class ReduceClass extends Reducer{
  9.  
  10. @Override
  11. protected void reduce(Text key, Iterable values,
  12. Context context)
  13. throws IOException, InterruptedException {
  14.  
  15. int sum = 0;
  16. Iterator valuesIt = values.iterator();
  17.  
  18. while(valuesIt.hasNext()){
  19. sum = sum + valuesIt.next().get();
  20. }
  21.  
  22. context.write(key, new IntWritable(sum));
  23. }
  24. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement