(func: &str, frame: WindowFrame, order_by: Vec<(SqlExpr, bool)>)
| 433 | } |
| 434 | |
| 435 | fn agg_spec(func: &str, frame: WindowFrame, order_by: Vec<(SqlExpr, bool)>) -> WindowFuncSpec { |
| 436 | WindowFuncSpec { |
| 437 | alias: format!("w_{func}"), |
| 438 | func_name: func.to_string(), |
| 439 | args: vec![col("v")], |
| 440 | partition_by: vec![], |
| 441 | order_by, |
| 442 | frame, |
| 443 | } |
| 444 | } |
| 445 | |
| 446 | /// Drive `apply_v_aggregate` over the whole single-partition row set the |
| 447 | /// same way `evaluate_window_functions_value` does (push a Null cell, then |