(
(let $1 (OptionalType (DataType 'Int32)))
(let $2 (DqPhyStage '() (lambda '() (block '(
  (let $6 '@@["StructType";[["key";["DataType";"String"]];["subkey";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
  (let $7 (YqlRowSpec '('NativeYtTypeFlags '0) '('StrictSchema '1) '('UniqueKeys '0) '('Type $6)))
  (let $8 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0) '('Attrs '('('"native_strict_schema" '"false")))))
  (let $9 (YtStat '('Id '"Input") '('RecordsCount '"4") '('DataSize '"190") '('ChunkCount '1) '('ModifyTime '0) '('Revision '0)))
  (let $10 (YtTable '"Input" $7 $8 $9 '() (Void) (Void) '"/Root/plato"))
  (let $11 '('"key" '"subkey" '"value"))
  (let $12 (YtReadTable! world (DataSource '"yt" '"/Root/plato") '((YtSection '((YtPath $10 $11 (Void) (Void))) '()))))
  (return (FromFlow (NarrowFlatMap (WideFilter (DqReadWideWrap $12 '()) (lambda '($13 $14 $15) (== $15 (String '"aaa")))) (lambda '($16 $17 $18) (block '(
    (let $19 (DataType 'String))
    (let $20 (OptionalType (DataType 'Bool)))
    (let $21 (CallableType '('"3") '((ListType $19)) '((OptionalType $19)) '($19) '($20 '"DelimeterString") '($20 '"SkipEmpty") '((OptionalType (DataType 'Uint64)) '"Limit")))
    (let $22 (Udf '"String.SplitToList" (Void) (VoidType) '"" $21 (VoidType) '"" '('('"strict"))))
    (let $23 (String '","))
    (return (OrderedMap (Collect (Apply $22 (Just $16) $23)) (lambda '($24) (block '(
      (let $25 (Apply $22 (Just $17) $23))
      (return (AsStruct '('event_id (SafeCast $24 $1)) '('"test_ids" (OrderedMap $25 (lambda '($26) (SafeCast $26 $1))))))
    )))))
  ))))))
))) '('('"_logical_id" '1838) '('"_id" '"990f4bac-8cf14235-a1af77c7-33e7a0c0"))))
(let $3 (DqCnUnionAll (TDqOutput $2 '0)))
(let $4 (DqPhyStage '($3) (lambda '($27) $27) '('('"_logical_id" '1904) '('"_id" '"3721df94-a91ec7e7-79754ff7-16abd32a"))))
(let $5 (DqCnResult (TDqOutput $4 '0) '('event_id '"test_ids")))
(return (KqpPhysicalQuery '((KqpPhysicalTx '($2 $4) '($5) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType (StructType '('event_id $1) '('"test_ids" (ListType $1)))) '0 '0)) '('('"type" '"query"))))
)
