aboutsummaryrefslogtreecommitdiffstats
path: root/yql/essentials/tests/sql/suites/aggr_factory/bottom_by.sql
blob: f5ee53bd8c9b855b1f849a7e8234fae861a5b81e (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
/* syntax version 1 */
/* postgres can not */
$t = AsList(
    AsStruct(1 as key, 101 as value),
    AsStruct(6 as key, 34 as value),
    AsStruct(4 as key, 22 as value),
    AsStruct(2 as key, 256 as value),
    AsStruct(7 as key, 111 as value)
);

$f = AGGREGATION_FACTORY("bottomby", 3);

select Yql::Aggregate($t, AsTuple(), AsTuple(AsTuple(AsAtom("res"),
    $f(ListItemType(TypeOf($t)), ($z)->{ return AsTuple($z.value, $z.key) }))));

use plato;
insert into @a select AsTuple(value, key) as vk from as_table($t);
commit;

select AGGREGATE_BY(vk, $f) from @a;