Method toMutationProto

src/AppendRequest.java:544–577

()

  }

  @Override
  MutationProto toMutationProto() {
    final MutationProto.ColumnValue.Builder columns =  // All columns ...
      MutationProto.ColumnValue.newBuilder()
      .setFamily(Bytes.wrap(family));                  // ... for this family.

    // Now add all the qualifier-value pairs.
    for (int i = 0; i < qualifiers.length; i++) {
      final MutationProto.ColumnValue.QualifierValue column =
        MutationProto.ColumnValue.QualifierValue.newBuilder()
        .setQualifier(Bytes.wrap(qualifiers[i]))
        .setValue(Bytes.wrap(values[i]))
        .setTimestamp(timestamp)
        .build();
      columns.addQualifierValue(column);
    }

    final MutationProto.Builder append = MutationProto.newBuilder()
      .setRow(Bytes.wrap(key))
      .setMutateType(MutationProto.MutationType.APPEND)
      .addColumnValue(columns);
    if (!durable) {
      append.setDurability(MutationProto.Durability.SKIP_WAL);
    }
    
    //Set return results flag
    HBasePB.NameBytesPair nameBytePair = HBasePB.NameBytesPair.getDefaultInstance();
    append.addAttribute(nameBytePair.toBuilder().
            setNameBytes(ByteString.copyFrom(RETURN_RESULTS)).
            setValue(ByteString.copyFrom(
                return_result ? new byte[] { -1 } : new byte[] { 0 })));
    
    return append.build();
  }

  /** Serializes this request.  */
  @Override