(
(let $1 (DataType 'String))
(let $2 (StructType '('"a" $1) '('aa $1) '('"c" $1) '('"key" $1) '('"subkey" $1) '('"value" $1)))
(let $3 '('('"_logical_id" '1458) '('"_id" '"578478c8-c87d1141-c7171422-23c4626a") '('"_wide_channels" $2)))
(let $4 (DqPhyStage '() (lambda '() (block '(
  (let $8 (OptionalType (DataType 'Bool)))
  (let $9 (CallableType '('3) '((ListType $1)) '((OptionalType $1)) '($1) '($8 '"DelimeterString") '($8 '"SkipEmpty") '((OptionalType (DataType 'Uint64)) '"Limit")))
  (let $10 (Udf '"String.SplitToList" (Void) (VoidType) '"" $9 (VoidType) '"" '('('"strict"))))
  (let $11 (String '"075,020,075,020"))
  (let $12 (Apply $10 (Just $11) (String '",")))
  (let $13 (Condense1 (ToFlow (OrderedFlatMap (DictPayloads (ToDict (OrderedMap $12 (lambda '($16) (AsStruct '('"a" $11) '('aa $16) '('"c" (String '"x"))))) (lambda '($17) '((Member $17 'aa))) (lambda '($18) $18) '('Auto 'Many))) (lambda '($19) $19))) (lambda '($20) $20) (lambda '($21 $22) (AggrNotEquals (Member $21 'aa) (Member $22 'aa))) (lambda '($23 $24) $24)))
  (let $14 '('Many 'Hashed 'Compact))
  (let $15 (SqueezeToDict (Map $13 (lambda '($25) '((Member $25 'aa) $25))) (lambda '($26) (Nth $26 '0)) (lambda '($27) (Nth $27 '1)) $14))
  (return (FromFlow (WideSort (FlatMap $15 (lambda '($28) (block '(
    (let $29 '@@["StructType";[["key";["DataType";"String"]];["subkey";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
    (let $30 (YqlRowSpec '('NativeYtTypeFlags '0) '('StrictSchema '1) '('UniqueKeys '0) '('Type $29)))
    (let $31 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0) '('Attrs '('('"native_strict_schema" '"false")))))
    (let $32 (YtStat '('Id '"Input") '('RecordsCount '4) '('DataSize '"166") '('ChunkCount '1) '('ModifyTime '0) '('Revision '0)))
    (let $33 (YtTable '"Input" $30 $31 $32 '() (Void) (Void) '"/Root/plato"))
    (let $34 '('"key" '"subkey" '"value"))
    (let $35 (YtReadTable! world (DataSource '"yt" '"/Root/plato") '((YtSection '((YtPath $33 $34 (Void) (Void))) '()))))
    (let $36 '('0 '3 '1 '4 '2 '5))
    (let $37 '('"a" '0 'aa '1 '"c" '2))
    (return (MapJoinCore (DqReadWideWrap $35 '()) $28 '"Inner" '('0) '('aa) $36 $37 '('"y.key") '('"x.aa")))
  )))) '('('1 (Bool 'true))))))
))) $3))
(let $5 (DqCnMerge (TDqOutput $4 '0) '('('1 '"Asc"))))
(let $6 (DqPhyStage '($5) (lambda '($38) (FromFlow (NarrowMap (ToFlow $38) (lambda '($39 $40 $41 $42 $43 $44) (AsStruct '('"a" $39) '('aa $40) '('"c" $41) '('"key" $42) '('"subkey" $43) '('"value" $44)))))) '('('"_logical_id" '1470) '('"_id" '"1605f378-9577a2d0-45bc22cd-6a09bbb3"))))
(let $7 (DqCnResult (TDqOutput $6 '0) '()))
(return (KqpPhysicalQuery '((KqpPhysicalTx '($4 $6) '($7) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType $2) '0 '0)) '('('"type" '"query"))))
)
