(
row: &[Value],
column_index: &HashMap<String, usize>,
partition_by: &[SqlExpr],
)
| 115 | } |
| 116 | |
| 117 | fn partition_key( |
| 118 | row: &[Value], |
| 119 | column_index: &HashMap<String, usize>, |
| 120 | partition_by: &[SqlExpr], |
| 121 | ) -> String { |
| 122 | partition_by |
| 123 | .iter() |
| 124 | .map(|expr| { |
| 125 | let v = eval_arg_for_row(expr, row, column_index); |
| 126 | format!("{v:?}") |
| 127 | }) |
| 128 | .collect::<Vec<_>>() |
| 129 | .join("\x00") |
| 130 | } |
| 131 | |
| 132 | // ── Value comparison helpers (pub(super) for value_agg) ─────────────────────── |
| 133 |
no test coverage detected