Method serialize

src/CompareAndSetRequest.java:161–214

(byte server_version)

  }

  @Override
  ChannelBuffer serialize(byte server_version) {
    if (server_version < RegionClient.SERVER_VERSION_095_OR_ABOVE) {
      return serializeOld(server_version);
    }

    final ByteString key = Bytes.wrap(put.key());
    final ByteString family = Bytes.wrap(put.family());
    final ByteString qualifier = Bytes.wrap(put.qualifier());
    final ByteString value = Bytes.wrap(put.value());

    // The edit.
    final MutationProto.ColumnValue.QualifierValue qual =
      MutationProto.ColumnValue.QualifierValue.newBuilder()
      .setQualifier(qualifier)
      .setValue(value)
      .setTimestamp(put.timestamp())
      .build();
    final MutationProto.ColumnValue column =
      MutationProto.ColumnValue.newBuilder()
      .setFamily(family)
      .addQualifierValue(qual)
      .build();
    final MutationProto.Builder put = MutationProto.newBuilder()
      .setRow(key)
      .setMutateType(MutationProto.MutationType.PUT)
      .addColumnValue(column);

    // The condition that needs to match for the edit to be applied.
    final ByteArrayComparable expected = ByteArrayComparable.newBuilder()
      .setValue(Bytes.wrap(this.expected))
      .build();
    final BinaryComparator cmp = BinaryComparator.newBuilder()
      .setComparable(expected)
      .build();
    final Comparator comparator = Comparator.newBuilder()
      .setNameBytes(BINARYCOMPARATOR)
      .setSerializedComparator(Bytes.wrap(cmp.toByteArray()))
      .build();
    final Condition cond = Condition.newBuilder()
      .setRow(key)
      .setFamily(family)
      .setQualifier(qualifier)
      .setCompareType(CompareType.EQUAL)
      .setComparator(comparator)
      .build();

    final MutateRequest req = MutateRequest.newBuilder()
      .setRegion(region.toProtobuf())
      .setMutation(put.build())
      .setCondition(cond)
      .build();
    return toChannelBuffer(MUTATE, req);
  }

  /** Serializes this request for HBase 0.94 and before.  */
  private ChannelBuffer serializeOld(final byte server_version) {