Method scanFinished

src/Scanner.java:936–974

(boolean end)

  }

  private Deferred<ArrayList<ArrayList<KeyValue>>> scanFinished(boolean end) {
    final byte[] region_stop_key = region.stopKey();
    final byte[] region_start_key = RegionInfo.startKeyFromRegionName(
            region.name());
    // Check to see if this region is the last we should scan (either
    // because (1) it's the last region or (3) because its stop_key is
    // greater than or equal to the stop_key of this scanner provided
    // that (2) we're not trying to scan until the end of the table).
    // or if the scanner is reversed, (4) it's the first region or
    // (6) scanner is in reverse and stop_key is after the region start_key
    // provided that (5) we are not trying to scan until the beginning.
    if ((!is_reversed &&
        (region_stop_key == EMPTY_ARRAY ||                            // (1)
          (stop_key != EMPTY_ARRAY &&                                 // (2)
          Bytes.memcmp(stop_key, region_stop_key) <= 0 )))            // (3)
      || (is_reversed &&
        (region_start_key == EMPTY_ARRAY ||                           // (4)
          (stop_key != EMPTY_ARRAY &&                                 // (5)
          Bytes.memcmp(stop_key, region_start_key) >= 0)))){          // (6)

      get_next_rows_request = null;        // free();
      families = null;                     // free();
      qualifiers = null;                   // free();
      start_key = stop_key = EMPTY_ARRAY;  // free() but mustn't be null.
      if (end) {
        return Deferred.fromResult(null);  // The server already closed the scanner for us.
      }
      return close()  // Auto-close the scanner.
        .addCallback(new Callback<ArrayList<ArrayList<KeyValue>>, Object>() {
          public ArrayList<ArrayList<KeyValue>> call(final Object arg) {
            return null;  // Tell the user there's nothing more to scan.
          }
          public String toString() {
            return "auto-close scanner " + Bytes.hex(scanner_id);
          }
        });
    }
    return continueScanOnNextRegion();
  }

  /**
   * Continues scanning on the next region.