(final ChannelBuffer buf, final int cell_size)
| 1515 | } |
| 1516 | |
| 1517 | @Override |
| 1518 | Response deserialize(final ChannelBuffer buf, final int cell_size) { |
| 1519 | final ScanResponse resp = readProtobuf(buf, ScanResponse.PARSER); |
| 1520 | final long id = resp.getScannerId(); |
| 1521 | if (scanner_id != id) { |
| 1522 | throw new InvalidResponseException("Scan RPC response was for scanner" |
| 1523 | + " ID " + id + " but we expected" |
| 1524 | + scanner_id, resp); |
| 1525 | } |
| 1526 | final ArrayList<ArrayList<KeyValue>> rows = getRows(resp, buf, cell_size); |
| 1527 | if (rows == null) { |
| 1528 | return null; |
| 1529 | } |
| 1530 | final boolean scannerClosedOnServer = resp.hasMoreResultsInRegion() && !resp.getMoreResultsInRegion(); |
| 1531 | return new Response(resp.getScannerId(), rows, resp.getMoreResults(), scannerClosedOnServer); |
| 1532 | } |
| 1533 | |
| 1534 | public String toString() { |
| 1535 | return "GetNextRowsRequest(scanner_id=" + Bytes.hex(scanner_id) |
nothing calls this directly
no test coverage detected