bool AsyncScanRpcRetryingCaller::NoMoreResultsForScan()

in src/hbase/client/async-scan-rpc-retrying-caller.cc [354:368]


bool AsyncScanRpcRetryingCaller::NoMoreResultsForScan(const Scan& scan,
                                                      const pb::RegionInfo& info) {
  if (BytesUtil::IsEmptyStopRow(info.end_key())) {
    return true;
  }
  if (BytesUtil::IsEmptyStopRow(scan.StopRow())) {
    return false;
  }
  int32_t c = BytesUtil::CompareTo(info.end_key(), scan.StopRow());
  // 1. if our stop row is less than the endKey of the region
  // 2. if our stop row is equal to the endKey of the region and we do not include the stop row
  // for scan.
  return c > 0 ||
         (c == 0 /* && !scan.IncludeStopRow()*/);  // TODO: Scans always exclude StopRow for now.
}