MCPcopy Create free account
hub / github.com/OpenTSDB/asynchbase / deserialize

Method deserialize

src/Scanner.java:1463–1474  ·  view source on GitHub ↗
(final ChannelBuffer buf, final int cell_size)

Source from the content-addressed store, hash-verified

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() + ')';

Callers

nothing calls this directly

Calls 2

readProtobufMethod · 0.80
getRowsMethod · 0.80

Tested by

no test coverage detected