InMemAllAny.yqls 1017 B

123456789101112131415161718192021222324252627282930
  1. (
  2. (library "joins.yql")
  3. (import join_module '"joins.yql")
  4. (let config (DataSource 'config))
  5. # Same as InputKV1
  6. (let list1 (AsList
  7. (AsStruct '('key (String '1)) '('v1 (String 'v11)))
  8. (AsStruct '('key (String '2)) '('v1 (String 'v12)))
  9. (AsStruct '('key (String '2)) '('v1 (String 'v12)))
  10. (AsStruct '('key (String '2)) '('v1 (String 'v12)))
  11. (AsStruct '('key (String '3)) '('v1 (String 'v13)))
  12. (AsStruct '('key (String '3)) '('v1 (String 'v13)))
  13. ))
  14. # Same as InputKV2
  15. (let list2 (AsList
  16. (AsStruct '('key (String '2)) '('v2 (String 'v22_extra_bytes)))
  17. (AsStruct '('key (String '2)) '('v2 (String 'v22_extra_bytes)))
  18. (AsStruct '('key (String '3)) '('v2 (String 'v23_extra_bytes)))
  19. (AsStruct '('key (String '3)) '('v2 (String 'v23_extra_bytes)))
  20. (AsStruct '('key (String '3)) '('v2 (String 'v23_extra_bytes)))
  21. (AsStruct '('key (String '4)) '('v2 (String 'v24_extra_bytes)))
  22. ))
  23. (let world (Apply (bind join_module 'doAllJoinsExceptCrossEx) world list1 list2 '('('right 'any))))
  24. (return world)
  25. )