yt_shuffle_by_keys.sql 501 B

1234567891011121314151617181920212223
  1. --Test, that YT optimizer can rewrite ShuffleByKeys with PartitionsByKes
  2. USE plato;
  3. $input = PROCESS Input;
  4. SELECT YQL::ShuffleByKeys(
  5. $input,
  6. ($_)->("dsdsa"),
  7. ($_)->([1]) -- list
  8. );
  9. SELECT YQL::ShuffleByKeys(
  10. $input,
  11. ($_)->(12),
  12. ($_)->(Just(2)) -- optional
  13. );
  14. SELECT YQL::ShuffleByKeys(
  15. $input,
  16. ($_)->(true),
  17. ($_)->(YQL::ToStream([3])) -- stream
  18. );