(
(let $1 (DataType 'String))
(let $2 (OptionalType $1))
(let $3 '('"key" '"subkey" '"value"))
(let $4 (DqPhyStage '() (lambda '() (block '(
  (let $8 '('"3"))
  (let $9 '((StreamType (StructType '('"Data" $1)))))
  (let $10 '($1))
  (let $11 (ListType $1))
  (let $12 '($2))
  (let $13 (CallableType $8 $9 $9 $10 '((OptionalType $11)) $12 $12))
  (let $14 (Udf '"Streaming.Process" (Void) (VoidType) '"" $13 (VoidType) '"" '()))
  (let $15 '@@["StructType";[["key";["DataType";"String"]];["subkey";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
  (let $16 (YqlRowSpec '('NativeYtTypeFlags '0) '('StrictSchema '1) '('UniqueKeys '0) '('Type $15)))
  (let $17 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0) '('Attrs '('('"native_strict_schema" '"false")))))
  (let $18 (YtStat '('Id '"Input1") '('RecordsCount '"9") '('DataSize '"360") '('ChunkCount '1) '('ModifyTime '0) '('Revision '0)))
  (let $19 (YtTable '"Input1" $16 $17 $18 '() (Void) (Void) '"/Root/plato"))
  (let $20 (YtReadTable! world (DataSource '"yt" '"/Root/plato") '((YtSection '((YtPath $19 $3 (Void) (Void))) '()))))
  (let $21 '('('"strict")))
  (let $22 (String '","))
  (return (FromFlow (Map (ToFlow (Apply $14 (FromFlow (NarrowMap (DqReadWideWrap $20 '()) (lambda '($23 $24 $25) (block '(
    (let $26 '((ListType $2) '"" '1))
    (let $27 (CallableType '() $10 $26 $10))
    (let $28 (Udf '"String.JoinFromList" (Void) (VoidType) '"" $27 (VoidType) '"" $21))
    (let $29 (AsList (Just $23) (Just $24) (Just $25)))
    (let $30 (Apply $28 $29 $22))
    (return (AsStruct '('"Data" $30)))
  ))))) (String '"grep") (Just (AsList (String '"[14]"))))) (lambda '($31) (block '(
    (let $32 (OptionalType (DataType 'Uint64)))
    (let $33 (lambda '($38) (block '(
      (let $39 (OptionalType (DataType 'Bool)))
      (let $40 (CallableType $8 '($11) $12 $10 '($39 '"DelimeterString") '($39 '"SkipEmpty") '($32 '"Limit")))
      (let $41 (Udf '"String.SplitToList" (Void) (VoidType) '"" $40 (VoidType) '"" $21))
      (return (Lookup (ToIndexDict (Apply $41 (Just (Member $31 '"Data")) $22)) $38))
    ))))
    (let $34 (Nothing $2))
    (let $35 (IfPresent (SafeCast (Int32 '0) $32) $33 $34))
    (let $36 (IfPresent (SafeCast (Int32 '1) $32) $33 $34))
    (let $37 (IfPresent (SafeCast (Int32 '"2") $32) $33 $34))
    (return (AsStruct '('"key" $35) '('"subkey" $36) '('"value" $37)))
  ))))))
))) '('('"_logical_id" '1393) '('"_id" '"7a93f8eb-4e0bedd9-f149b95d-1fd19269"))))
(let $5 (DqCnUnionAll (TDqOutput $4 '0)))
(let $6 (DqPhyStage '($5) (lambda '($42) $42) '('('"_logical_id" '1444) '('"_id" '"102155ae-2665b2aa-624771c-30a190cb"))))
(let $7 (DqCnResult (TDqOutput $6 '0) $3))
(return (KqpPhysicalQuery '((KqpPhysicalTx '($4 $6) '($7) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType (StructType '('"key" $2) '('"subkey" $2) '('"value" $2))) '0 '0)) '('('"type" '"query"))))
)
