Method addStep

src/QueryPlan/QueryPlan.cpp:147–192

}

void QueryPlan::addStep(QueryPlanStepPtr step, PlanNodes children)
{
    (void)children;
    checkNotCompleted();

    size_t num_input_streams = step->getInputStreams().size();
    if (num_input_streams == 0)
    {
        if (isInitialized())
            throw Exception(
                "Cannot add step " + step->getName()
                    + " to QueryPlan because "
                      "step has no inputs, but QueryPlan is already initialized",
                ErrorCodes::LOGICAL_ERROR);

        nodes.emplace_back(Node{.step = std::move(step)});
        root = &nodes.back();
        return;
    }
    else
    {
        if (!isInitialized())
            throw Exception(
                "Cannot add step " + step->getName()
                    + " to QueryPlan because "
                      "step has input, but QueryPlan is not initialized",
                ErrorCodes::LOGICAL_ERROR);

        const auto & root_header = root->step->getOutputStream().header;
        const auto & step_header = step->getInputStreams().front().header;
        if (!blocksHaveEqualStructure(root_header, step_header))
            throw Exception(
                "Cannot add step " + step->getName()
                    + " to QueryPlan because "
                      "it has incompatible header with root step "
                    + root->step->getName()
                    + " "
                      "root header: "
                    + root_header.dumpStructure() + "step header: " + step_header.dumpStructure(),
                ErrorCodes::LOGICAL_ERROR);

        nodes.emplace_back(Node{.step = std::move(step), .children = {root}});
        root = &nodes.back();
        return;
    }
}

void QueryPlan::addNode(Node && node_)
{