client-mr/core/src/main/java/org/apache/hadoop/mapred/SortWriteBuffer.java [61:80]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public int addRecord(K key, V value) throws IOException {
    keySerializer.open(this);
    valSerializer.open(this);
    int lastOffSet = currentOffset;
    int lastIndex = currentIndex;
    int lastDataLength = dataLength;
    int keyIndex = lastIndex;
    keySerializer.serialize(key);
    int keyLength = dataLength - lastDataLength;
    int keyOffset = lastOffSet;
    if (compact(lastIndex, lastOffSet, keyLength)) {
      keyOffset = lastOffSet;
      keyIndex = lastIndex;
    }
    lastDataLength = dataLength;
    valSerializer.serialize(value);
    int valueLength = dataLength - lastDataLength;
    records.add(new Record<K>(keyIndex, keyOffset, keyLength, valueLength));
    return keyLength + valueLength;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/buffer/WriteBuffer.java [66:85]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public int addRecord(K key, V value) throws IOException {
    keySerializer.open(this);
    valSerializer.open(this);
    int lastOffSet = currentOffset;
    int lastIndex = currentIndex;
    int lastDataLength = dataLength;
    int keyIndex = lastIndex;
    keySerializer.serialize(key);
    int keyLength = dataLength - lastDataLength;
    int keyOffset = lastOffSet;
    if (compact(lastIndex, lastOffSet, keyLength)) {
      keyOffset = lastOffSet;
      keyIndex = lastIndex;
    }
    lastDataLength = dataLength;
    valSerializer.serialize(value);
    int valueLength = dataLength - lastDataLength;
    records.add(new Record<K>(keyIndex, keyOffset, keyLength, valueLength));
    return keyLength + valueLength;
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -