123456789101112131415161718192021222324252627 |
- (
- (let config (DataSource 'config))
- (let list1 (AsList
- (AsStruct '('key1 (Int32 '1)) '('value1 (String 'A)))
- (AsStruct '('key1 (Int32 '7)) '('value1 (String 'B)))
- (AsStruct '('key1 (Int32 '4)) '('value1 (String 'C)))
- (AsStruct '('key1 (Int32 '4)) '('value1 (String 'D)))
- ))
- (let list2 (AsList
- (AsStruct '('key2 (Int32 '9)) '('value2 (String 'Z)))
- (AsStruct '('key2 (Int32 '4)) '('value2 (String 'Y)))
- (AsStruct '('key2 (Int32 '3)) '('value2 (String 'X)))
- (AsStruct '('key2 (Int32 '4)) '('value2 (String 'W)))
- (AsStruct '('key2 (Int32 '8)) '('value2 (String 'V)))
- ))
- (let joinInner (EquiJoin '(list1 'a) '(list2 'b) '('Inner 'a 'b '('a 'key1) '('b 'key2) '())
- '('('rename '"a.key1" 'q) '('rename '"b.value2" '""))))
- (let res_sink (DataSink 'result))
- (let world (Write! world res_sink (Key) joinInner '('('type))))
- (let world (Commit! world res_sink))
- (return world)
- )
|