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


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
26
27

/* syntax version 1 */
/* postgres can not */
USE plato;

$f1 = ($r)->{
   return $r;
};

PROCESS Input0 USING $f1(TableRow());

$f2 = ($r)->{
   return Just($r);
};

PROCESS Input0 USING $f2(TableRow());

$f3 = ($r)->{
   return AsList($r,$r);
};

PROCESS Input0 USING $f3(TableRow());

$f4 = ($r)->{
   return Yql::Iterator(AsList($r,$r));
};

PROCESS Input0 USING $f4(TableRow());