in tephra-hbase-compat-2.0-base/src/main/java/org/apache/tephra/hbase/coprocessor/FilteredInternalScanner.java [52:80]
public boolean next(List<Cell> result, ScannerContext scannerContext) throws IOException {
outResult.clear();
if (filter.filterAllRemaining()) { return false; }
while (true) {
boolean next = delegate.next(outResult, scannerContext);
for (Cell cell : outResult) {
ReturnCode code = filter.filterKeyValue(cell);
switch (code) {
// included, so we are done
case INCLUDE:
case INCLUDE_AND_NEXT_COL:
result.add(cell);
break;
case SKIP:
case NEXT_COL:
case NEXT_ROW:
default:
break;
}
}
if (!next) {
return next;
}
if (!result.isEmpty()) {
return true;
}
}
}