yql/essentials/tests/sql/suites/window/udaf_no_merge.sql


1
2
3
4
5
6
7
8
9
10
11

/* postgres can not */
/* syntax version 1 */
$f = AggregationFactory(
       "UDAF",
       ($item, $_) -> ($item),
       ($state, $item, $_) -> ($state),
       null,
       ($state) -> ($state)
);
    
select aggregate_by(x,$f) over (order by x) from (values (1),(2),(3)) as a(x);