client-mr/core/src/main/java/org/apache/hadoop/mapred/SortWriteBuffer.java [220:233]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void write(int b) throws IOException {
    if (buffers.isEmpty()) {
      buffers.add(new WrappedBuffer((int) maxSegmentSize));
    }
    if (1 + currentOffset > maxSegmentSize) {
      currentIndex++;
      currentOffset = 0;
      buffers.add(new WrappedBuffer((int) maxSegmentSize));
    }
    WrappedBuffer buffer = buffers.get(currentIndex);
    buffer.getBuffer()[currentOffset] = (byte) b;
    currentOffset++;
    dataLength++;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/buffer/WriteBuffer.java [182:195]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public void write(int b) throws IOException {
    if (buffers.isEmpty()) {
      buffers.add(new WrappedBuffer((int) maxSegmentSize));
    }
    if (1 + currentOffset > maxSegmentSize) {
      currentIndex++;
      currentOffset = 0;
      buffers.add(new WrappedBuffer((int) maxSegmentSize));
    }
    WrappedBuffer buffer = buffers.get(currentIndex);
    buffer.getBuffer()[currentOffset] = (byte) b;
    currentOffset++;
    dataLength++;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



