Function plan_table_function_internal

src/sql/src/plan/query.rs:3280–3438

Plans a table function. You generally should call `plan_rows_from` or `plan_solitary_table_function` instead to get the appropriate aliasing behavior.

(
    qcx: &QueryContext,
    Function {
        name,
        args,
        filter,
        over,
        distinct,
    }: &Function<Aug>,
    with_ordinality: bool,
    table_name: Option<FullItemNa

/// You generally should call `plan_rows_from` or `plan_solitary_table_function`
/// instead to get the appropriate aliasing behavior.
fn plan_table_function_internal(
    qcx: &QueryContext,
    Function {
        name,
        args,
        filter,
        over,
        distinct,
    }: &Function<Aug>,
    with_ordinality: bool,
    table_name: Option<FullItemName>,
) -> Result<(HirRelationExpr, Scope), PlanError> {
    // The parser rejects FILTER, OVER, and DISTINCT in every table function
    // position (`FROM f(...)`, `ROWS FROM (...)`), and table functions in
    // scalar position are only lifted into a `FROM` clause when all three are
    // absent, so these are defensive.
    if filter.is_some() {
        sql_bail!("FILTER is not allowed for table functions in FROM");
    }
    if over.is_some() {
        sql_bail!("OVER is not allowed for table functions in FROM");
    }
    if *distinct {
        sql_bail!("DISTINCT is not allowed for table functions in FROM");
    }

    let ecx = &ExprContext {
        qcx,
        name: "table function arguments",
        scope: &Scope::empty(),
        relation_type: &SqlRelationType::empty(),
        allow_aggregates: false,
        allow_subqueries: true,
        allow_parameters: true,
        allow_windows: false,
    };

    let scalar_args = match args {
        FunctionArgs::Star => sql_bail!("{} does not accept * as an argument", name),
        FunctionArgs::Args { args, order_by } => {
            if !order_by.is_empty() {
                sql_bail!(
                    "ORDER BY specified, but {} is not an aggregate function",
                    name
                );
            }
            plan_exprs(ecx, args)?
        }
    };

    let table_name = match table_name {
        Some(table_name) => table_name.item,
        None => name.full_item_name().item.clone(),
    };

    let scope_name = Some(PartialItemName {
        database: None,
        schema: None,