fn fused_value_window_func<'a, I>(
input_datums: I,
callers_temp_storage: &'a RowArena,
funcs: &Vec<AggregateFunc>,
order_by: &Vec<ColumnOrder>,
) -> Datum<'a>where
I: IntoIterator<Item = Datum<'a>>,
Expand description
Executes FusedValueWindowFunc
on a reduction group.
The expected input is in the format of [((OriginalRow, (Args1, Args2, ...)), OrderByExprs...)]
where Args1
, Args2
, are the arguments of each of the fused functions. For functions that
have only a single argument (first_value/last_value), these are simple values. For functions
that have multiple arguments (lag/lead), these are also records.