(
(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 (YtStat '('Id '"Input") '('RecordsCount '"14") '('DataSize '"614") '('ChunkCount '1) '('ModifyTime '0) '('Revision '0)))
(let $6 (YtTable '"Input" $3 $4 $5 '() (Void) (Void) '"/Root/plato"))
(let $7 (DataType 'Uint32))
(let $8 (OptionalType $7))
(let $9 '('('"_logical_id" '2333) '('"_id" '"12f8e762-8010c9aa-f59f32be-844ebf72") '('"_wide_channels" (StructType '('"k" $8)))))
(let $10 (DqPhyStage '() (lambda '() (block '(
  (let $24 (YtReadTable! world $1 '((YtSection '((YtPath $6 '('"key") (Void) (Void))) '()))))
  (return (FromFlow (WideMap (DqReadWideWrap $24 '()) (lambda '($25) (SafeCast $25 $8)))))
))) $9))
(let $11 (DqCnBroadcast (TDqOutput $10 '0)))
(let $12 (lambda '($49 $50) $50 $49))
(let $13 (ListType $7))
(let $14 '('aval (DataType 'String)))
(let $15 '('('"_logical_id" '2488) '('"_id" '"f724d3d0-7132665e-db45af5d-12d916dd") '('"_wide_channels" (StructType '('_yql_agg_0 $13) $14))))
(let $16 (DqPhyStage '($11) (lambda '($26) (block '(
  (let $27 '('One 'Hashed 'Compact))
  (let $28 (SqueezeToDict (NarrowFlatMap (WideFilter (ToFlow $26) (lambda '($29) (Exists $29))) (lambda '($30) $30)) (lambda '($31) $31) (lambda '($32) (Void)) $27))
  (return (WideFromBlocks (DqPhyHashCombine (WideToBlocks (FromFlow (FlatMap $28 (lambda '($33) (block '(
    (let $34 (YtReadTable! world $1 '((YtSection '((YtPath $6 '('"subkey" '"value") (Void) (Void))) '()))))
    (let $35 (lambda '($37 $38) (SafeCast $37 $8) $38))
    (let $36 '('0 '0 '1 '1))
    (return (MapJoinCore (WideMap (DqReadWideWrap $34 '()) $35) $33 'LeftOnly '('0) '('"k") $36 '() '('"a.k") '('"b.k")))
  )))))) '-1073741824 (lambda '($39 $40) $40) (lambda '($41 $42 $43) (ToList $42)) (lambda '($44 $45 $46 $47) (IfPresent $45 (lambda '($48) (Insert $47 $48)) $47)) $12)))
))) $15))
(let $17 (DqCnHashShuffle (TDqOutput $16 '0) '('1) '0 '"HashV2"))
(let $18 '('('"_logical_id" '3047) '('"_id" '"cf86988f-96b2b483-ae78b612-7ee46a9c") '('"_partition_mode" '"aggregate")))
(let $19 (DqPhyStage '($17) (lambda '($51) (block '(
  (let $52 (WideCombiner (ToFlow $51) '"" (lambda '($53 $54) $54) (lambda '($55 $56 $57) $56) (lambda '($58 $59 $60 $61) (Extend $59 $61)) $12))
  (return (FromFlow (NarrowMap $52 (lambda '($62 $63) (AsStruct '('aval $63) '('"column0" $62))))))
))) $18))
(let $20 (DqCnUnionAll (TDqOutput $19 '0)))
(let $21 (DqPhyStage '($20) (lambda '($64) $64) '('('"_logical_id" '3373) '('"_id" '"39a5712d-9563469f-f8d2fafb-979697ca"))))
(let $22 '($10 $16 $19 $21))
(let $23 (DqCnResult (TDqOutput $21 '0) '('"column0" 'aval)))
(return (KqpPhysicalQuery '((KqpPhysicalTx $22 '($23) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType (StructType $14 '('"column0" $13))) '0 '0)) '('('"type" '"query"))))
)
