(
(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 '('ChunkCount '1))
(let $7 '('ModifyTime '0))
(let $8 '('Revision '0))
(let $9 (DataType 'String))
(let $10 '('"subkey" $9))
(let $11 '('"value" $9))
(let $12 '('('"_logical_id" '3272) '('"_id" '"e856808-49ac1b2e-6c595870-26b81c94") '('"_wide_channels" (StructType $10 $11))))
(let $13 (DqPhyStage '() (lambda '() (block '(
  (let $30 (YtStat '('Id '"Input2") $5 '('DataSize '"178") $6 $7 $8))
  (let $31 (YtTable '"Input2" $3 $4 $30 '() (Void) (Void) '"/Root/plato"))
  (let $32 (YtReadTable! world $1 '((YtSection '((YtPath $31 '('"subkey" '"value") (Void) (Void) (Void))) '()))))
  (return (FromFlow (DqReadWideWrap $32 '())))
))) $12))
(let $14 (DqCnBroadcast (TDqOutput $13 '0)))
(let $15 '('DataSize '"166"))
(let $16 '('"key" '"value"))
(let $17 (StructType '('"l_1.key" $9) '('"l_1.value" $9) '('"r_1.subkey" $9) '('"r_1.value" $9)))
(let $18 '('('"_logical_id" '3356) '('"_id" '"97d45b1f-f3715565-e7db746d-1f7c119d") '('"_wide_channels" $17)))
(let $19 (DqPhyStage '($14) (lambda '($33) (block '(
  (let $34 (Condense1 (NarrowMap (ToFlow $33) (lambda '($36 $37) (AsStruct '('"subkey" $36) '('"value" $37)))) (lambda '($38) (AsList $38)) (lambda '($39 $40) (Bool '"false")) (lambda '($41 $42) (Append $42 $41))))
  (let $35 (lambda '($50) (Member $50 '"l_1.key") (Member $50 '"l_1.value") (Member $50 '"r_1.subkey") (Member $50 '"r_1.value")))
  (return (FromFlow (ExpandMap (FlatMap $34 (lambda '($43) (block '(
    (let $44 (YtStat '('Id '"Input1") $5 $15 $6 $7 $8))
    (let $45 (YtTable '"Input1" $3 $4 $44 '() (Void) (Void) '"/Root/plato"))
    (let $46 (YtReadTable! world $1 '((YtSection '((YtPath $45 $16 (Void) (Void) (Void))) '()))))
    (return (NarrowFlatMap (DqReadWideWrap $46 '()) (lambda '($47 $48) (Map (Collect $43) (lambda '($49) (AsStruct '('"l_1.key" $47) '('"l_1.value" $48) '('"r_1.subkey" (Member $49 '"subkey")) '('"r_1.value" (Member $49 '"value"))))))))
  )))) $35)))
))) $18))
(let $20 '"_equijoin_column_0")
(let $21 '('('"_logical_id" '3384) '('"_id" '"352e88f3-257197d1-78ff7464-1fefc874") '('"_wide_channels" (StructType '($20 $9) $11))))
(let $22 (DqPhyStage '() (lambda '() (block '(
  (let $51 (YtStat '('Id '"Input3") $5 $15 $6 $7 $8))
  (let $52 (YtTable '"Input3" $3 $4 $51 '() (Void) (Void) '"/Root/plato"))
  (let $53 (YtReadTable! world $1 '((YtSection '((YtPath $52 $16 (Void) (Void) (Void))) '()))))
  (let $54 (lambda '($55 $56) (Concat (String '"") $55) $56))
  (return (FromFlow (WideMap (DqReadWideWrap $53 '()) $54)))
))) $21))
(let $23 (DqCnMap (TDqOutput $19 '0)))
(let $24 (DqCnBroadcast (TDqOutput $22 '0)))
(let $25 (DqPhyStage '($23 $24) (lambda '($57 $58) (block '(
  (let $59 '('Many 'Hashed 'Compact))
  (let $60 (NarrowSqueezeToDict (ToFlow $58) (lambda '($61 $62) $61) (lambda '($63 $64) (AsStruct '($20 $63) '('"value" $64))) $59))
  (return (FromFlow (NarrowMap (FlatMap $60 (lambda '($65) (block '(
    (let $66 '('0 '0 '1 '1 '2 '3 '3 '4))
    (return (MapJoinCore (ToFlow $57) $65 'Left '('0) '($20) $66 '('"value" '2) '('"l_1.key") '('"r._equijoin_column_0")))
  )))) (lambda '($67 $68 $69 $70 $71) (AsStruct '('"key" $67) '('"rvalue" $69) '('"subkey" $70) '('"value" (Concat $68 $71)))))))
))) '('('"_logical_id" '3518) '('"_id" '"d901d6a1-9c7ca2e-1634655e-a0a0b4f5"))))
(let $26 (DqCnUnionAll (TDqOutput $25 '0)))
(let $27 (DqPhyStage '($26) (lambda '($72) $72) '('('"_logical_id" '3917) '('"_id" '"9ab18774-e2829c62-684decfd-5b351914"))))
(let $28 '($13 $19 $22 $25 $27))
(let $29 (DqCnResult (TDqOutput $27 '0) '()))
(return (KqpPhysicalQuery '((KqpPhysicalTx $28 '($29) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType (StructType '('"key" $9) '('"rvalue" (OptionalType $9)) $10 $11)) '0 '0)) '('('"type" '"query"))))
)
