Serializes this request for HBase 0.94 and before.
(final byte server_version)
| 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) { |
no test coverage detected