Method lookupRange

src/processor/operator/scan/primary_key_scan_node_table.cpp:88–160

}

bool PrimaryKeyScanNodeTable::lookupRange(ExecutionContext* context) {
    auto transaction = transaction::Transaction::Get(*context->clientContext);
    while (currentRangeTableIdx < tableInfos.size()) {
        auto& tableInfo = tableInfos[currentRangeTableIdx];
        auto& table = tableInfo.table->cast<NodeTable>();
        if (rangeOffsets.empty()) {
            ValueVector* lowerBoundVector = nullptr;
            uint64_t lowerPos = 0;
            if (indexEvaluator != nullptr) {
                indexEvaluator->evaluate();
                lowerBoundVector = indexEvaluator->resultVector.get();
                auto& lowerSelVector = lowerBoundVector->state->getSelVector();
                DASSERT(lowerSelVector.getSelSize() == 1);
                lowerPos = lowerSelVector.getSelectedPositions()[0];
                if (lowerBoundVector->isNull(lowerPos)) {
                    currentRangeTableIdx++;
                    continue;
                }
            }

            ValueVector* upperBoundVector = nullptr;
            uint64_t upperPos = 0;
            if (upperBoundEvaluator != nullptr) {
                upperBoundEvaluator->evaluate();
                upperBoundVector = upperBoundEvaluator->resultVector.get();
                auto& upperSelVector = upperBoundVector->state->getSelVector();
                DASSERT(upperSelVector.getSelSize() == 1);
                upperPos = upperSelVector.getSelectedPositions()[0];
                if (upperBoundVector->isNull(upperPos)) {
                    currentRangeTableIdx++;
                    continue;
                }
            }
            static constexpr auto maxRangeResults = std::numeric_limits<common::idx_t>::max();
            const auto found =
                indexName.empty() ?
                    table.lookupPKRange(transaction, lowerBoundVector, lowerPos, lowerInclusive,
                        upperBoundVector, upperPos, upperInclusive, maxRangeResults, rangeOffsets) :
                isIndexEquality ? table.lookupIndex(transaction, indexName, lowerBoundVector,
                                      lowerPos, rangeOffsets) :
                                  table.lookupIndexRange(transaction, indexName, lowerBoundVector,
                                      lowerPos, lowerInclusive, upperBoundVector, upperPos,
                                      upperInclusive, maxRangeResults, rangeOffsets);
            if (!found) {
                currentRangeTableIdx++;
                continue;
            }
        }

        const auto remaining = rangeOffsets.size() - rangeOffsetCursor;
        if (remaining == 0) {
            rangeOffsets.clear();
            rangeOffsetCursor = 0;
            currentRangeTableIdx++;
            continue;
        }
        const auto outputSize = std::min<uint64_t>(remaining, common::DEFAULT_VECTOR_CAPACITY);
        auto& selVector = scanState->nodeIDVector->state->getSelVectorUnsafe();