Function run_agg

nodedb-query/src/window/value_agg.rs:449–456

Drive `apply_v_aggregate` over the whole single-partition row set the same way `evaluate_window_functions_value` does (push a Null cell, then fill it), returning the produced column.

(rows: &mut [Vec<Value>], cols: &HashMap<String, usize>, spec: &WindowFuncSpec)

    /// same way `evaluate_window_functions_value` does (push a Null cell, then
    /// fill it), returning the produced column.
    fn run_agg(rows: &mut [Vec<Value>], cols: &HashMap<String, usize>, spec: &WindowFuncSpec) {
        let write_col = rows.first().map(|r| r.len()).unwrap_or(0);
        for row in rows.iter_mut() {
            row.push(Value::Null);
        }
        let indices: Vec<usize> = (0..rows.len()).collect();
        apply_v_aggregate(rows, &indices, cols, spec, write_col);
    }

    fn frame(mode: &str, start: FrameBound, end: FrameBound) -> WindowFrame {
        WindowFrame {