Serializes this request.
(final byte server_version)
| 1495 | |
| 1496 | /** Serializes this request. */ |
| 1497 | ChannelBuffer serialize(final byte server_version) { |
| 1498 | if (server_version < RegionClient.SERVER_VERSION_095_OR_ABOVE) { |
| 1499 | final ChannelBuffer buf = newBuffer(server_version, |
| 1500 | 4 + 1 + 8 + 1 + 4); |
| 1501 | buf.writeInt(2); // Number of parameters. |
| 1502 | writeHBaseLong(buf, scanner_id); |
| 1503 | writeHBaseInt(buf, max_num_rows); |
| 1504 | return buf; |
| 1505 | } |
| 1506 | |
| 1507 | final ScanRequest req = ScanRequest.newBuilder() |
| 1508 | .setScannerId(scanner_id) |
| 1509 | .setNumberOfRows(max_num_rows) |
| 1510 | // Hardcoded these parameters to false since AsyncHBase cannot support them |
| 1511 | .setClientHandlesHeartbeats(false) |
| 1512 | .setClientHandlesPartials(false) |
| 1513 | .build(); |
| 1514 | return toChannelBuffer(SCAN, req); |
| 1515 | } |
| 1516 | |
| 1517 | @Override |
| 1518 | Response deserialize(final ChannelBuffer buf, final int cell_size) { |
nothing calls this directly
no test coverage detected