process_with_lambda_outstream.sql 384 B

123456789101112131415161718192021222324252627
  1. /* syntax version 1 */
  2. /* postgres can not */
  3. USE plato;
  4. $f1 = ($r)->{
  5. return $r;
  6. };
  7. PROCESS Input0 USING $f1(TableRow());
  8. $f2 = ($r)->{
  9. return Just($r);
  10. };
  11. PROCESS Input0 USING $f2(TableRow());
  12. $f3 = ($r)->{
  13. return AsList($r,$r);
  14. };
  15. PROCESS Input0 USING $f3(TableRow());
  16. $f4 = ($r)->{
  17. return Yql::Iterator(AsList($r,$r));
  18. };
  19. PROCESS Input0 USING $f4(TableRow());