(final ChannelBuffer buf, final int cell_size)
| 1461 | } |
| 1462 | |
| 1463 | @Override |
| 1464 | Response deserialize(final ChannelBuffer buf, final int cell_size) { |
| 1465 | final ScanResponse resp = readProtobuf(buf, ScanResponse.PARSER); |
| 1466 | if (!resp.hasScannerId()) { |
| 1467 | throw new InvalidResponseException("Scan RPC response doesn't contain a" |
| 1468 | + " scanner ID", resp); |
| 1469 | } |
| 1470 | final boolean scannerClosedOnServer = resp.hasMoreResultsInRegion() && !resp.getMoreResultsInRegion(); |
| 1471 | return new Response(resp.getScannerId(), |
| 1472 | getRows(resp, buf, cell_size), |
| 1473 | resp.getMoreResults(), scannerClosedOnServer); |
| 1474 | } |
| 1475 | |
| 1476 | public String toString() { |
| 1477 | return "OpenScannerRequest(scanner=" + Scanner.this.toString() + ')'; |
nothing calls this directly
no test coverage detected