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


1
2
3
4
5
6
7
8
9
10
11
12

/* postgres can not */
/* multirun can not */
/* syntax version 1 */
use plato;

$udf = YQL::@@(lambda '(x) 
(FlatMap x 
   (lambda '(y) (Just (AsStruct '('key (Concat (String '"0") (Member y 'key))) '('subkey (Member y 'subkey)) '('value (Member y 'value)))))
))@@;

insert into Output with truncate
process plato.Input using $udf(TableRows()) assume order by key;