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

#include "processor/plan_mapper.h"

using namespace lbug::planner;

namespace lbug {
namespace processor {

static PhysicalOperator* getTableScan(const PhysicalOperator* joinRoot) {
    auto op = joinRoot->getChild(0);
    while (op->getOperatorType() != PhysicalOperatorType::TABLE_FUNCTION_CALL) {
        DASSERT(op->getNumChildren() != 0);
        op = op->getChild(0);
    }
    return op;
}

void PlanMapper::mapSIPJoin(PhysicalOperator* joinRoot) {
    auto tableScan = getTableScan(joinRoot);
    auto resultCollector = tableScan->moveUnaryChild();
    joinRoot->addChild(std::move(resultCollector));
}

} // namespace processor
} // namespace lbug