12345678910111213 |
- /* syntax version 1 */
- /* postgres can not */
- $t = AsList(AsStruct(1 as a),AsStruct(2 as a));
- $f = AGGREGATION_FACTORY("sum_if");
- select Yql::Aggregate($t, AsTuple(), AsTuple(AsTuple(AsAtom("res"), $f(
- ListItemType(TypeOf($t)), ($z)->{return AsTuple($z.a,$z.a>1)}))));
- use plato;
- insert into @a select AsTuple(a,a>1) as aa from as_table($t);
- commit;
- select AGGREGATE_BY(aa,$f) from @a;
|