ydb/yql/essentials/tests/s-expressions/suites/Join/MapJoinCore.yqls

(
(let mr_source (DataSource 'yt 'plato))
(let list1 (AsList 
  (AsStruct '('key1 (Just (Int32 '1))) '('value1 (String 'A))) 
  (AsStruct '('key1 (Just (Int32 '7))) '('value1 (String 'B))) 
  (AsStruct '('key1 (Nothing (OptionalType (DataType 'Int32)))) '('value1 (String 'C)))
  (AsStruct '('key1 (Just (Int32 '4))) '('value1 (String 'D)))   
  (AsStruct '('key1 (Just (Int32 '4))) '('value1 (String 'E)))
))

(let list2 (AsList 
  (AsStruct '('key2 (Int64 '9)) '('value2 (String 'Z))) 
  (AsStruct '('key2 (Int64 '4)) '('value2 (String 'Y))) 
  (AsStruct '('key2 (Int64 '3)) '('value2 (String 'X)))
  (AsStruct '('key2 (Int64 '4)) '('value2 (String 'W)))
  (AsStruct '('key2 (Int64 '8)) '('value2 (String 'V)))
))

(let keyExtractor (lambda '(x) (Member x 'key2)))
(let payloadExtractor (lambda '(x) x))

(let dictOne (ToDict list2 keyExtractor payloadExtractor '('Hashed 'One 'Compact)))
(let dictMany (ToDict list2 keyExtractor payloadExtractor '('Hashed 'Many 'Compact)))
(let joinLeftSemi (MapJoinCore (Iterator list1 (DependsOn (String 'LeftSemi))) dictOne 'LeftSemi '('key1) '('key2) '('key1 'a.key1 'value1 'a.value1) '() '() '()))
(let joinLeftOnly (MapJoinCore (Iterator list1 (DependsOn (String 'LeftOnly))) dictOne 'LeftOnly '('key1) '('key2) '('key1 'a.key1 'key1 'another_key 'key1 'yet_another_key) '() '() '()))
(let joinInnerUnique (MapJoinCore (Iterator list1 (DependsOn (String 'InnerU))) dictOne 'Inner '('key1) '('key2) '('key1 'a.key1 'value1 'a.value1) '('value2 'b.value2) '() '()))
(let joinLeftUnique (MapJoinCore (Iterator list1 (DependsOn (String 'LeftU))) dictOne 'Left '('key1) '('key2) '('key1 'a.key1) '('key2 'b.key2 'value2 'b.value2) '() '()))
(let joinInner (MapJoinCore (Iterator list1 (DependsOn (String 'Inner))) dictMany 'Inner '('key1) '('key2) '('key1 'a.key1 'value1 'a.value1) '('key2 'b.key2) '() '()))
(let joinLeft (MapJoinCore (Iterator list1 (DependsOn (String 'Left))) dictMany 'Left '('key1) '('key2) '('key1 'a.key1) '('key2 'b.key2 'value2 'b.value2) '() '()))

(let res_sink (DataSink 'result))
(let world (Write! world res_sink (Key) (Collect joinLeftSemi) '('('type))))
(let world (Write! world res_sink (Key) (Collect joinLeftOnly) '('('type))))
(let world (Write! world res_sink (Key) (Collect joinInnerUnique) '('('type))))
(let world (Write! world res_sink (Key) (Collect joinLeftUnique) '('('type))))
(let world (Write! world res_sink (Key) (Collect joinInner) '('('type))))
(let world (Write! world res_sink (Key) (Collect joinLeft) '('('type))))

(let world (Commit! world res_sink))
(return world)
)