Method getPhysicalPlan

src/function/table/table_function.cpp:89–117

}

std::unique_ptr<PhysicalOperator> TableFunction::getPhysicalPlan(PlanMapper* planMapper,
    const LogicalOperator* logicalOp) {
    std::vector<DataPos> outPosV;
    auto& call = logicalOp->constCast<LogicalTableFunctionCall>();
    auto outSchema = call.getSchema();
    for (auto& expr : call.getBindData()->columns) {
        outPosV.emplace_back(planMapper->getDataPos(*expr, *outSchema));
    }
    auto info = TableFunctionCallInfo();
    info.function = call.getTableFunc();
    info.bindData = call.getBindData()->copy();
    info.outPosV = outPosV;
    auto initInput =
        TableFuncInitSharedStateInput(info.bindData.get(), planMapper->executionContext);
    auto sharedState = info.function.initSharedStateFunc(initInput);
    // Filter columns for print info based on column skips
    binder::expression_vector printExprs;
    auto columnSkips = call.getBindData()->getColumnSkips();
    for (auto i = 0u; i < call.getBindData()->columns.size(); ++i) {
        if (columnSkips.empty() || !columnSkips[i]) {
            printExprs.push_back(call.getBindData()->columns[i]);
        }
    }
    auto desc = call.getBindData()->getDescription();
    auto printInfo = std::make_unique<TableFunctionCallPrintInfo>(
        desc.empty() ? call.getTableFunc().name : desc, printExprs);
    return std::make_unique<TableFunctionCall>(std::move(info), sharedState,
        planMapper->getOperatorID(), std::move(printInfo));
}

offset_t TableFunction::emptyTableFunc(const TableFuncInput&, TableFuncOutput&) {
    // DO NOTHING.