Guest User

Untitled

a guest
Aug 18th, 2018
81
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.41 KB | None | 0 0
  1. Hadoop combiner sort phase
  2. sorter.sort(MapOutputBuffer.this, kvstart, endPosition, reporter);
  3.  
  4. sorter.sort(MapOutputBuffer.this, kvstart, endPosition, reporter);
  5. // some fields
  6. for (int i = 0; i < partitions; ++i) {
  7. // check if configured
  8. if (combinerRunner == null) {
  9. // spill directly
  10. } else {
  11. combinerRunner.combine(kvIter, combineCollector);
  12. }
  13. }
Add Comment
Please, Sign In to add comment