lbug 0.16.1

An in-process property graph database management system built for query speed and scalability
Documentation 
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
39
40
41
42
43

#include "planner/operator/logical_cross_product.h"
#include "planner/planner.h"

using namespace lbug::binder;
using namespace lbug::common;

namespace lbug {
namespace planner {

void Planner::appendCrossProduct(const LogicalPlan& probePlan, const LogicalPlan& buildPlan,
    LogicalPlan& resultPlan) {
    appendCrossProduct(AccumulateType::REGULAR, nullptr /* mark */, probePlan, buildPlan,
        resultPlan);
}

void Planner::appendOptionalCrossProduct(std::shared_ptr<Expression> mark,
    const LogicalPlan& probePlan, const LogicalPlan& buildPlan, LogicalPlan& resultPlan) {
    appendCrossProduct(AccumulateType::OPTIONAL_, mark, probePlan, buildPlan, resultPlan);
}

void Planner::appendAccOptionalCrossProduct(std::shared_ptr<Expression> mark,
    LogicalPlan& probePlan, const LogicalPlan& buildPlan, LogicalPlan& resultPlan) {
    DASSERT(probePlan.hasUpdate());
    tryAppendAccumulate(probePlan);
    appendCrossProduct(AccumulateType::OPTIONAL_, mark, probePlan, buildPlan, resultPlan);
    auto& sipInfo = resultPlan.getLastOperator()->cast<LogicalCrossProduct>().getSIPInfoUnsafe();
    sipInfo.direction = SIPDirection::PROBE_TO_BUILD;
}

void Planner::appendCrossProduct(AccumulateType accumulateType, std::shared_ptr<Expression> mark,
    const LogicalPlan& probePlan, const LogicalPlan& buildPlan, LogicalPlan& resultPlan) {
    auto crossProduct = make_shared<LogicalCrossProduct>(accumulateType, mark,
        probePlan.getLastOperator(), buildPlan.getLastOperator(),
        cardinalityEstimator.estimateCrossProduct(probePlan.getLastOperatorRef(),
            buildPlan.getLastOperatorRef()));
    crossProduct->computeFactorizedSchema();
    // update cost
    resultPlan.setCost(probePlan.getCardinality() + buildPlan.getCardinality());
    resultPlan.setLastOperator(std::move(crossProduct));
}

} // namespace planner
} // namespace lbug