client-mr/core/src/main/java/org/apache/hadoop/mapred/SortWriteBuffer.java [71:110]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    this.serializerInstance = serializerInstance;
    if (useUniffleSerializer) {
      this.dataOutputStream = new DataOutputStream(this);
    }
  }

  public int addRecord(K key, V value) throws IOException {
    if (!useUniffleSerializer) {
      keySerializer.open(this);
      valSerializer.open(this);
    }
    int lastOffSet = currentOffset;
    int lastIndex = currentIndex;
    int lastDataLength = dataLength;
    int keyIndex = lastIndex;
    if (useUniffleSerializer) {
      serializerInstance.serialize(key, this.dataOutputStream);
    } else {
      keySerializer.serialize(key);
    }
    int keyLength = dataLength - lastDataLength;
    int keyOffset = lastOffSet;
    if (compact(lastIndex, lastOffSet, keyLength)) {
      keyOffset = lastOffSet;
      keyIndex = lastIndex;
    }
    lastDataLength = dataLength;
    if (useUniffleSerializer) {
      serializerInstance.serialize(value, this.dataOutputStream);
    } else {
      valSerializer.serialize(value);
    }
    int valueLength = dataLength - lastDataLength;
    records.add(new Record<K>(keyIndex, keyOffset, keyLength, valueLength));
    return keyLength + valueLength;
  }

  public void clear() {
    buffers.clear();
    records.clear();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/buffer/WriteBuffer.java [73:113]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    this.serializerInstance = serializerInstance;
    if (useUniffleSerializer) {
      this.dataOutputStream = new DataOutputStream(this);
    }
  }

  /** add records */
  public int addRecord(K key, V value) throws IOException {
    if (!useUniffleSerializer) {
      keySerializer.open(this);
      valSerializer.open(this);
    }
    int lastOffSet = currentOffset;
    int lastIndex = currentIndex;
    int lastDataLength = dataLength;
    int keyIndex = lastIndex;
    if (useUniffleSerializer) {
      serializerInstance.serialize(key, this.dataOutputStream);
    } else {
      keySerializer.serialize(key);
    }
    int keyLength = dataLength - lastDataLength;
    int keyOffset = lastOffSet;
    if (compact(lastIndex, lastOffSet, keyLength)) {
      keyOffset = lastOffSet;
      keyIndex = lastIndex;
    }
    lastDataLength = dataLength;
    if (useUniffleSerializer) {
      serializerInstance.serialize(value, this.dataOutputStream);
    } else {
      valSerializer.serialize(value);
    }
    int valueLength = dataLength - lastDataLength;
    records.add(new Record<K>(keyIndex, keyOffset, keyLength, valueLength));
    return keyLength + valueLength;
  }

  public void clear() {
    buffers.clear();
    records.clear();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -