lbug 0.21.0

An in-process property graph database management system built for query speed and scalability
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

#include "expression_evaluator/internal_id_evaluator.h"

using namespace lbug::common;
using namespace lbug::main;
using namespace lbug::processor;
using namespace lbug::storage;

namespace lbug {
namespace evaluator {

void InternalIDExpressionEvaluator::resolveResultVector(const ResultSet& /*resultSet*/,
    MemoryManager* memoryManager) {
    resultVector =
        std::make_shared<ValueVector>(LogicalType(LogicalTypeID::INTERNAL_ID), memoryManager);
    std::vector<ExpressionEvaluator*> inputEvaluators{children[0].get()};
    resolveResultStateFromChildren(inputEvaluators);
}

void InternalIDExpressionEvaluator::evaluate() {
    for (auto& child : children) {
        child->evaluate();
    }
    auto& baseVector = children[0]->resultVector;
    auto& selVector = baseVector->state->getSelVector();
    for (auto i = 0u; i < selVector.getSelSize(); ++i) {
        auto pos = selVector[i];
        resultVector->setValue<nodeID_t>(pos, baseVector->getValue<nodeID_t>(pos));
        resultVector->setNull(pos, baseVector->isNull(pos));
    }
}

bool InternalIDExpressionEvaluator::selectInternal(SelectionVector& selVector) {
    evaluate();
    return updateSelectedPos(selVector);
}

} // namespace evaluator
} // namespace lbug