1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
/* syntax version 1 */
/* postgres can not */
/* syntax version 1 */
$create = ($item, $_parent) -> { return AsList($item) };
$add = ($state, $item, $_parent) -> { return Yql::Append($state, $item) };
$merge = ($state1, $state2) -> { return ListExtend($state1,$state2) };
$get_result = ($state) -> { return $state };
$serialize = ($state) -> { return $state };
$deserialize = ($state) -> { return $state };
$default = ($result_type)->{ return Yql::List($result_type) };
$udaf_factory = AGGREGATION_FACTORY(
"UDAF",
$create,
$add,
$merge,
$get_result,
$serialize,
$deserialize,
$default
);
select ListAggregate(AsList(1,2),$udaf_factory);
select ListAggregate(ListCreate(Int32),$udaf_factory);
|
