Method getRows

src/Scanner.java:1217–1248

Extracts the rows from the given ScanResponse. @param resp The protobuf of the RPC response. @param buf The buffer the response was read from. The actual KeyValues of the response will be read from there if cell blocks are in use. @param cell_size The number of bytes of the cell block that

(final ScanResponse resp,
                                                 final ChannelBuffer buf,
                                                 final int cell_size)

   * in the buffer.
   */
  private ArrayList<ArrayList<KeyValue>> getRows(final ScanResponse resp,
                                                 final ChannelBuffer buf,
                                                 final int cell_size) {
    final int nrows = (cell_size == 0
                       ? resp.getResultsCount()
                       : resp.getCellsPerResultCount());
    if (nrows == 0) {
      return null;
    }
    HBaseRpc.checkArrayLength(buf, nrows);
    final ArrayList<ArrayList<KeyValue>> rows =
      new ArrayList<ArrayList<KeyValue>>(nrows);
    if (cell_size != 0) {
      KeyValue kv = null;
      for (int i = 0; i < nrows; i++) {
        final int nkvs = resp.getCellsPerResult(i);
        HBaseRpc.checkArrayLength(buf, nkvs);
        final ArrayList<KeyValue> row = new ArrayList<KeyValue>(nkvs);
        for (int j = 0; j < nkvs; j++) {
          final int kv_length = buf.readInt();
          kv = KeyValue.fromBuffer(buf, kv);
          row.add(kv);
        }
        rows.add(row);
      }
    } else {
      for (int i = 0; i < nrows; i++) {
        rows.add(GetRequest.convertResult(resp.getResults(i), buf, cell_size));
      }
    }
    return rows;
  }

  /** RPC method name to use with HBase 0.95+.  */
  private static final byte[] SCAN = new byte[] { 'S', 'c', 'a', 'n' };