Function parse_def_source

src/expr-parser/src/parser.rs:1437–1474

(ctx: CtxRef, input: ParseStream)

    }

    fn parse_def_source(ctx: CtxRef, input: ParseStream) -> syn::Result<Def> {
        let reduce = input.parse::<def::DefSource>()?;

        let name = {
            input.parse::<def::name>()?;
            input.parse::<syn::Token![=]>()?;
            input.parse::<syn::Ident>()?.to_string()
        };

        let keys = if input.eat(kw::keys) {
            input.parse::<syn::Token![=]>()?;
            let inner;
            syn::bracketed!(inner in input);
            inner.parse_comma_sep(|input| {
                let inner;
                syn::bracketed!(inner in input);
                inner.parse_comma_sep(scalar::parse_column_index)
            })?
        } else {
            vec![]
        };

        let parse_inputs = ParseChildren::new(input, reduce.span().start());
        let (cols, column_types) = {
            let source_columns = parse_inputs.parse_many(ctx, parse_def_source_column)?;
            let mut column_names = vec![];
            let mut column_types = vec![];
            for (column_name, column_type) in source_columns {
                column_names.push(column_name);
                column_types.push(column_type);
            }
            (column_names, column_types)
        };

        let typ = SqlRelationType { column_types, keys };

        Ok(Def::Source { name, cols, typ })
    }

    fn parse_def_source_column(
        _ctx: CtxRef,