| 488 | } |
| 489 | |
| 490 | @Override |
| 491 | void serializePayload(final ChannelBuffer buf) { |
| 492 | if (family == null) { |
| 493 | return; // No payload when deleting whole rows. |
| 494 | } |
| 495 | // Are we deleting a whole family at once or just a bunch of columns? |
| 496 | final byte type = (qualifiers == DELETE_FAMILY_MARKER |
| 497 | ? KeyValue.DELETE_FAMILY |
| 498 | : (at_timestamp_only |
| 499 | ? KeyValue.DELETE |
| 500 | : KeyValue.DELETE_COLUMN)); |
| 501 | |
| 502 | // Write the KeyValues |
| 503 | for (final byte[] qualifier : qualifiers) { |
| 504 | KeyValue.serialize(buf, type, timestamp, |
| 505 | key, family, qualifier, null); |
| 506 | } |
| 507 | } |
| 508 | |
| 509 | /** |
| 510 | * Predicts a lower bound on the serialized size of this RPC. |