Method probe

src/processor/operator/path_property_probe.cpp:291–336

}

void PathPropertyProbe::probe(lbug::processor::JoinHashTable* hashTable, uint64_t sizeProbed,
    uint64_t sizeToProbe, ValueVector* idVector, const std::vector<ValueVector*>& propertyVectors,
    const std::vector<ft_col_idx_t>& colIndicesToScan, const char* pathElementType) const {
    // Hash
    for (auto i = 0u; i < sizeToProbe; ++i) {
        function::Hash::operation(idVector->getValue<internalID_t>(sizeProbed + i),
            localState.hashes[i]);
    }
    // Probe hash
    for (auto i = 0u; i < sizeToProbe; ++i) {
        localState.probedTuples[i] = hashTable->getTupleForHash(localState.hashes[i]);
    }
    // Match value
    for (auto i = 0u; i < sizeToProbe; ++i) {
        localState.matchedTuples[i] = nullptr;
        auto id = idVector->getValue<internalID_t>(sizeProbed + i);
        while (localState.probedTuples[i]) {
            auto currentTuple = localState.probedTuples[i];
            if (*(internalID_t*)currentTuple == id) {
                localState.matchedTuples[i] = currentTuple;
                break;
            }
            localState.probedTuples[i] = *hashTable->getPrevTuple(currentTuple);
        }
        if (localState.matchedTuples[i] == nullptr) {
            throw RuntimeException(std::format(
                "PathPropertyProbe failed to find {} property tuple for path element id "
                "{{tableID: {}, offset: {}}}. This indicates the {} property hash table is "
                "missing an ID produced by recursive path enumeration. hashTableEntries={}, "
                "pathDataOffset={}, probeBatchOffset={}.",
                pathElementType, id.tableID, id.offset, pathElementType, hashTable->getNumEntries(),
                sizeProbed + i, i));
        }
    }
    // Scan table
    auto factorizedTable = hashTable->getFactorizedTable();
    for (auto i = 0u; i < sizeToProbe; ++i) {
        auto tuple = localState.matchedTuples[i];
        for (auto j = 0u; j < propertyVectors.size(); ++j) {
            auto propertyVector = propertyVectors[j];
            auto colIdx = colIndicesToScan[j];
            factorizedTable->readFlatColToFlatVector(tuple, colIdx, *propertyVector,
                sizeProbed + i);
        }
    }
}

} // namespace processor
} // namespace lbug