Method continueScanOnNextRegion

src/Scanner.java:986–1019

Continues scanning on the next region. This method is called when we tried to get more rows but we reached the end of the current region and need to move on to the next region. This method closes the scanner on the current region, updates the start key of this scanner and resumes scanning on

()

   * @return The deferred results from the next region.
   */
  private Deferred<ArrayList<ArrayList<KeyValue>>> continueScanOnNextRegion() {
    // Copy those into local variables so we can still refer to them in the
    // "closure" below even after we've changed them.
    final long old_scanner_id = scanner_id;
    final RegionInfo old_region = region;
    if(LOG.isDebugEnabled()) {
      LOG.debug("Scanner " + Bytes.hex(old_scanner_id) + " done scanning "
              + old_region);
    }
    client.closeScanner(this).addCallback(new Callback<Object, Object>() {
      public Object call(final Object arg) {
        if(LOG.isDebugEnabled()) {
          LOG.debug("Scanner " + Bytes.hex(old_scanner_id) + " closed on "
                  + old_region);
        }
        return arg;
      }

      public String toString() {
        return "scanner moved";
      }
    });
    // Continue scanning from the next region's start key
    // Dependent on direction of scan
    if (is_reversed){
      start_key = RegionInfo.startKeyFromRegionName(region.name());
    } else{
      start_key = region.stopKey();
    }

    scanner_id = 0xDEAD000AA000DEADL;   // Make debugging easier.
    invalidate();
    return nextRows();
  }

  public String toString() {
    final String region = this.region == null ? "null"