Serializes this request.
(final byte server_version)
| 1562 | |
| 1563 | /** Serializes this request. */ |
| 1564 | ChannelBuffer serialize(final byte server_version) { |
| 1565 | if (server_version < RegionClient.SERVER_VERSION_095_OR_ABOVE) { |
| 1566 | final ChannelBuffer buf = newBuffer(server_version, |
| 1567 | 4 + 1 + 8); |
| 1568 | buf.writeInt(1); // Number of parameters. |
| 1569 | writeHBaseLong(buf, scanner_id); |
| 1570 | return buf; |
| 1571 | } |
| 1572 | final ScanRequest req = ScanRequest.newBuilder() |
| 1573 | .setScannerId(scanner_id) |
| 1574 | .setCloseScanner(true) |
| 1575 | .setNumberOfRows(0) |
| 1576 | .build(); |
| 1577 | return toChannelBuffer(SCAN, req); |
| 1578 | } |
| 1579 | |
| 1580 | @Override |
| 1581 | Object deserialize(final ChannelBuffer buf, final int cell_size) { |
nothing calls this directly
no test coverage detected