(
(let $1 (DataSource '"yt" '"/Root/plato"))
(let $2 '@@["StructType";[["key";["DataType";"String"]];["subkey";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
(let $3 (YqlRowSpec '('NativeYtTypeFlags '0) '('StrictSchema '1) '('UniqueKeys '0) '('Type $2)))
(let $4 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0) '('Attrs '('('"native_strict_schema" '"false")))))
(let $5 '('RecordsCount '"4"))
(let $6 '('DataSize '"166"))
(let $7 '('ChunkCount '1))
(let $8 '('ModifyTime '0))
(let $9 '('Revision '0))
(let $10 (DataType 'String))
(let $11 '('('"_logical_id" '1012) '('"_id" '"efeacb21-63b17c05-97f5181f-81508984") '('"_wide_channels" (StructType '('"key" $10) '('"value" $10)))))
(let $12 (DqPhyStage '() (lambda '() (block '(
  (let $20 (YtStat '('Id '"Input3") $5 $6 $7 $8 $9))
  (let $21 (YtTable '"Input3" $3 $4 $20 '() (Void) (Void) '"/Root/plato"))
  (let $22 (YtReadTable! world $1 '((YtSection '((YtPath $21 '('"key" '"value") (Void) (Void))) '()))))
  (return (FromFlow (DqReadWideWrap $22 '())))
))) $11))
(let $13 (DqCnBroadcast (TDqOutput $12 '0)))
(let $14 (DqPhyStage '($13) (lambda '($23) (block '(
  (let $24 '('Many 'Hashed 'Compact))
  (let $25 (NarrowSqueezeToDict (ToFlow $23) (lambda '($26 $27) $26) (lambda '($28 $29) (AsStruct '('"key" $28) '('"value" $29))) $24))
  (return (FromFlow (NarrowMap (FlatMap $25 (lambda '($30) (block '(
    (let $31 (YtStat '('Id '"Input1") $5 $6 $7 $8 $9))
    (let $32 (YtTable '"Input1" $3 $4 $31 '() (Void) (Void) '"/Root/plato"))
    (let $33 (YtReadTable! world $1 '((YtSection '((YtPath $32 '('"key" '"subkey") (Void) (Void))) '()))))
    (let $34 '('0 '0 '1 '1))
    (return (MapJoinCore (DqReadWideWrap $33 '()) $30 'Inner '('0) '('"key") $34 '('"value" '2) '('"Input1.key") '('"Input3.key")))
  )))) (lambda '($35 $36 $37) (AsStruct '('"Input1.key" $35) '('"Input1.subkey" $36) '('"Input3.value" $37))))))
))) '('('"_logical_id" '1100) '('"_id" '"a65188b9-1e01db1-b9d067c8-c67fec90"))))
(let $15 (DqCnUnionAll (TDqOutput $14 '0)))
(let $16 (DqPhyStage '($15) (lambda '($38) $38) '('('"_logical_id" '1247) '('"_id" '"35462f0f-9a703510-183f9f37-706da4b4"))))
(let $17 '($12 $14 $16))
(let $18 '('"Input1.key" '"Input1.subkey" '"Input3.value"))
(let $19 (DqCnResult (TDqOutput $16 '0) $18))
(return (KqpPhysicalQuery '((KqpPhysicalTx $17 '($19) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType (StructType '('"Input1.key" $10) '('"Input1.subkey" $10) '('"Input3.value" $10))) '0 '0)) '('('"type" '"query"))))
)
