JoinInMemRename.yqls 899 B

123456789101112131415161718192021222324252627
  1. (
  2. (let config (DataSource 'config))
  3. (let list1 (AsList
  4. (AsStruct '('key1 (Int32 '1)) '('value1 (String 'A)))
  5. (AsStruct '('key1 (Int32 '7)) '('value1 (String 'B)))
  6. (AsStruct '('key1 (Int32 '4)) '('value1 (String 'C)))
  7. (AsStruct '('key1 (Int32 '4)) '('value1 (String 'D)))
  8. ))
  9. (let list2 (AsList
  10. (AsStruct '('key2 (Int32 '9)) '('value2 (String 'Z)))
  11. (AsStruct '('key2 (Int32 '4)) '('value2 (String 'Y)))
  12. (AsStruct '('key2 (Int32 '3)) '('value2 (String 'X)))
  13. (AsStruct '('key2 (Int32 '4)) '('value2 (String 'W)))
  14. (AsStruct '('key2 (Int32 '8)) '('value2 (String 'V)))
  15. ))
  16. (let joinInner (EquiJoin '(list1 'a) '(list2 'b) '('Inner 'a 'b '('a 'key1) '('b 'key2) '())
  17. '('('rename '"a.key1" 'q) '('rename '"b.value2" '""))))
  18. (let res_sink (DataSink 'result))
  19. (let world (Write! world res_sink (Key) joinInner '('('type))))
  20. (let world (Commit! world res_sink))
  21. (return world)
  22. )