(
(let $1 (DataSource '"yt" '"/Root/plato"))
(let $2 '('NativeYtTypeFlags '0))
(let $3 '('StrictSchema '1))
(let $4 '('UniqueKeys '0))
(let $5 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0) '('Attrs '('('"native_strict_schema" '"false")))))
(let $6 (YtStat '('Id '"Input") '('RecordsCount '"4") '('DataSize '"166") '('ChunkCount '1) '('ModifyTime '0) '('Revision '0)))
(let $7 (DqPhyStage '() (lambda '() (block '(
  (let $24 '@@["StructType";[["key";["DataType";"String"]];["subkey";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
  (let $25 (YqlRowSpec $2 $3 $4 '('Type $24)))
  (let $26 (YtTable '"Input" $25 $5 $6 '() (Void) (Void) '"/Root/plato"))
  (let $27 '('"key" '"subkey" '"value"))
  (let $28 (YtReadTable! world $1 '((YtSection '((YtPath $26 $27 (Void) (Void))) '()))))
  (return (FromFlow (NarrowMap (DqReadWideWrap $28 '()) (lambda '($29 $30 $31) (AsStruct '('"key" $29) '('"subkey" $30) '('"value" $31))))))
))) '('('"_logical_id" '1056) '('"_id" '"fd2fa672-99bd18a7-cb547212-d15e394c"))))
(let $8 (DqCnUnionAll (TDqOutput $7 '0)))
(let $9 (DqPhyStage '($8) (lambda '($32) $32) '('('"_logical_id" '1138) '('"_id" '"3ae70f73-ca58a4a7-1d40764c-323ff57"))))
(let $10 (DqCnResult (TDqOutput $9 '0) '()))
(let $11 '('('"type" '"generic")))
(let $12 (KqpPhysicalTx '($7 $9) '($10) '() $11))
(let $13 (DataType 'String))
(let $14 '('"key" $13))
(let $15 '('"value" $13))
(let $16 (StructType $14 $15))
(let $17 (DqPhyStage '() (lambda '() (block '(
  (let $33 '@@["StructType";[["key";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
  (let $34 (YqlRowSpec $2 $3 $4 '('Type $33)))
  (let $35 (YtTable '"Input" $34 $5 $6 '('('"userschema" $16)) (Void) (Void) '"/Root/plato"))
  (let $36 (YtReadTable! world $1 '((YtSection '((YtPath $35 '('"key" '"value") (Void) (Void))) '()))))
  (return (FromFlow (NarrowMap (DqReadWideWrap $36 '()) (lambda '($37 $38) (AsStruct '('"key" $37) '('"value" $38))))))
))) '('('"_logical_id" '1095) '('"_id" '"98c9dcdd-a29ec45a-7f4c6ad9-acf1b916"))))
(let $18 (DqCnUnionAll (TDqOutput $17 '0)))
(let $19 (DqPhyStage '($18) (lambda '($39) $39) '('('"_logical_id" '1245) '('"_id" '"47056dce-ee81fc55-6f595c56-fc8700e9"))))
(let $20 (DqCnResult (TDqOutput $19 '0) '()))
(let $21 (KqpPhysicalTx '($17 $19) '($20) '() $11))
(let $22 (KqpTxResultBinding (ListType (StructType $14 '('"subkey" $13) $15)) '0 '0))
(let $23 (KqpTxResultBinding (ListType $16) '1 '0))
(return (KqpPhysicalQuery '($12 $21) '($22 $23) '('('"type" '"query"))))
)
