Method deserialize

src/AppendRequest.java:633–653

(ChannelBuffer buf, int cell_size)

  }

  @Override
  Object deserialize(ChannelBuffer buf, int cell_size) {
    if (!this.return_result) {
      HBaseRpc.ensureNoCell(cell_size);
    }
    final ClientPB.MutateResponse resp = 
        readProtobuf(buf, ClientPB.MutateResponse.PARSER);
    final ClientPB.Result result = resp.getResult();
    if (this.return_result) {
      final ArrayList<KeyValue> kvs = GetRequest.convertResult(result,
          buf, cell_size);
      if (kvs.size() != 1) {
        throw new InvalidResponseException("Atomic increment returned "
          + kvs.size() + " KeyValue(s), but we expected exactly one. kvs="
          + kvs, resp);
      }
      return kvs.get(0);
    } else {
      return null;
    }
  }
}