Serializes this request for HBase 0.94 and before.
(final byte server_version)
| 215 | |
| 216 | /** Serializes this request for HBase 0.94 and before. */ |
| 217 | private ChannelBuffer serializeOld(final byte server_version) { |
| 218 | final ChannelBuffer buf = newBuffer(server_version, predictSerializedSize()); |
| 219 | buf.writeInt(6); // Number of parameters. |
| 220 | |
| 221 | // 1st param: byte array: region name. |
| 222 | writeHBaseByteArray(buf, region.name()); |
| 223 | |
| 224 | // 2nd param: byte array: row key. |
| 225 | writeHBaseByteArray(buf, put.key()); |
| 226 | |
| 227 | // 3rd param: byte array: column family. |
| 228 | writeHBaseByteArray(buf, put.family()); |
| 229 | |
| 230 | // 4th param: byte array: qualifier. |
| 231 | writeHBaseByteArray(buf, put.qualifier()); |
| 232 | |
| 233 | // 5th param: byte array: expected value. |
| 234 | writeHBaseByteArray(buf, expected); |
| 235 | |
| 236 | // 6th param: New value. |
| 237 | put.serializeInto(buf); |
| 238 | |
| 239 | return buf; |
| 240 | } |
| 241 | |
| 242 | @Override |
| 243 | Boolean deserialize(final ChannelBuffer buf, final int cell_size) { |
no test coverage detected