yql/essentials/tests/sql/suites/produce/reduce_row.yql


1
2
3
4
5
6
7
8

pragma warning("disable","4510");
$input = select 1 as key, 'foo' as value;

$f = ($key, $stream)->{
    return <|key:$key,len:ListLength(Yql::Collect($stream))|>
};

REDUCE $input ON key USING $f(TableRow());