lbug 0.18.1

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

#include "expression_evaluator/reference_evaluator.h"

using namespace lbug::common;
using namespace lbug::main;

namespace lbug {
namespace evaluator {

inline static bool isTrue(ValueVector& vector, uint64_t pos) {
    DASSERT(vector.dataType.getLogicalTypeID() == LogicalTypeID::BOOL);
    return !vector.isNull(pos) && vector.getValue<bool>(pos);
}

bool ReferenceExpressionEvaluator::selectInternal(SelectionVector& selVector) {
    uint64_t numSelectedValues = 0;
    auto selectedBuffer = selVector.getMutableBuffer();
    auto& resultSelVector = resultVector->state->getSelVector();
    if (resultSelVector.isUnfiltered()) {
        for (auto i = 0u; i < resultSelVector.getSelSize(); i++) {
            selectedBuffer[numSelectedValues] = i;
            numSelectedValues += isTrue(*resultVector, i);
        }
    } else {
        for (auto i = 0u; i < resultSelVector.getSelSize(); i++) {
            auto pos = resultSelVector[i];
            selectedBuffer[numSelectedValues] = pos;
            numSelectedValues += isTrue(*resultVector, pos);
        }
    }
    selVector.setSelSize(numSelectedValues);
    return numSelectedValues > 0;
}

} // namespace evaluator
} // namespace lbug