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.
}