MCPcopy Create free account
hub / github.com/OpenTSDB/asynchbase / serializeOld

Method serializeOld

src/DeleteRequest.java:614–642  ·  view source on GitHub ↗

Serializes this request for HBase 0.94 and before.

(final byte server_version)

Source from the content-addressed store, hash-verified

612
613 /** Serializes this request for HBase 0.94 and before. */
614 private ChannelBuffer serializeOld(final byte server_version) {
615 final ChannelBuffer buf = newBuffer(server_version,
616 predictSerializedSize());
617 buf.writeInt(2); // Number of parameters.
618
619 // 1st param: byte array containing region name
620 writeHBaseByteArray(buf, region.name());
621
622 // 2nd param: Delete object.
623 buf.writeByte(CODE); // Code for a `Delete' parameter.
624 buf.writeByte(CODE); // Code again (see HBASE-2877).
625 buf.writeByte(1); // Delete#DELETE_VERSION. Stick to v1 here for now.
626 writeByteArray(buf, key);
627 buf.writeLong(timestamp); // Maximum timestamp.
628 buf.writeLong(lockid); // Lock ID.
629
630 // Families.
631 if (family == WHOLE_ROW) {
632 buf.writeInt(0); // Number of families that follow.
633 return buf;
634 }
635 buf.writeInt(1); // Number of families that follow.
636
637 // Each family is then written like so:
638 writeByteArray(buf, family); // Column family name.
639 buf.writeInt(qualifiers.length); // How many KeyValues for this family?
640 serializePayload(buf);
641 return buf;
642 }
643
644 @Override
645 Object deserialize(final ChannelBuffer buf, int cell_size) {

Callers 1

serializeMethod · 0.95

Calls 6

predictSerializedSizeMethod · 0.95
serializePayloadMethod · 0.95
newBufferMethod · 0.80
writeHBaseByteArrayMethod · 0.80
writeByteArrayMethod · 0.80
nameMethod · 0.45

Tested by

no test coverage detected