process_with_assume.sql 366 B

123456789101112
  1. /* postgres can not */
  2. /* multirun can not */
  3. /* syntax version 1 */
  4. use plato;
  5. $udf = YQL::@@(lambda '(x)
  6. (FlatMap x
  7. (lambda '(y) (Just (AsStruct '('key (Concat (String '"0") (Member y 'key))) '('subkey (Member y 'subkey)) '('value (Member y 'value)))))
  8. ))@@;
  9. insert into Output with truncate
  10. process plato.Input using $udf(TableRows()) assume order by key;