Function parse_distinct

src/expr-parser/src/parser.rs:455–486

(ctx: CtxRef, input: ParseStream)

    }

    fn parse_distinct(ctx: CtxRef, input: ParseStream) -> Result {
        let reduce = input.parse::<kw::Distinct>()?;

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

        let monotonic = input.eat(kw::monotonic);

        let expected_group_size = if input.eat(kw::exp_group_size) {
            input.parse::<syn::Token![=]>()?;
            Some(input.parse::<syn::LitInt>()?.base10_parse::<u64>()?)
        } else {
            None
        };

        let parse_inputs = ParseChildren::new(input, reduce.span().start());
        let input = Box::new(parse_inputs.parse_one(ctx, parse_expr)?);

        Ok(MirRelationExpr::Reduce {
            input,
            group_key,
            aggregates: vec![],
            monotonic,
            expected_group_size,
        })
    }

    fn parse_reduce(ctx: CtxRef, input: ParseStream) -> Result {
        let reduce = input.parse::<kw::Reduce>()?;