Function extract_options

src/sql/src/plan/transform_hir.rs:435–486

Helper function to extract the above options.

(call: &HirScalarExpr)

    /// Helper function to extract the above options.
    fn extract_options(call: &HirScalarExpr) -> WindowFuncCallOptions {
        match call {
            HirScalarExpr::Windowing(
                WindowExpr {
                    func:
                        WindowExprType::Value(ValueWindowExpr {
                            order_by: inner_order_by,
                            window_frame,
                            ignore_nulls,
                            func: _,
                            args: _,
                        }),
                    partition_by,
                    order_by: outer_order_by,
                },
                _name,
            ) => WindowFuncCallOptions::Value(ValueWindowFuncCallOptions {
                partition_by: partition_by.clone(),
                outer_order_by: outer_order_by.clone(),
                inner_order_by: inner_order_by.clone(),
                window_frame: window_frame.clone(),
                ignore_nulls: ignore_nulls.clone(),
            }),
            HirScalarExpr::Windowing(
                WindowExpr {
                    func:
                        WindowExprType::Aggregate(AggregateWindowExpr {
                            aggregate_expr:
                                AggregateExpr {
                                    distinct,
                                    func: _,
                                    expr: _,
                                },
                            order_by: inner_order_by,
                            window_frame,
                        }),
                    partition_by,
                    order_by: outer_order_by,
                },
                _name,
            ) => WindowFuncCallOptions::Agg(AggregateWindowFuncCallOptions {
                partition_by: partition_by.clone(),
                outer_order_by: outer_order_by.clone(),
                inner_order_by: inner_order_by.clone(),
                window_frame: window_frame.clone(),
                distinct: distinct.clone(),
            }),
            _ => panic!(
                "extract_options should only be called on value window functions or window aggregations"
            ),
        }
    }

    struct FusionGroup {
        /// The original column index of the first element of the group. (This is an index into the