(
(let $1 (DataSource '"yt" '"/Root/plato"))
(let $2 '('NativeYtTypeFlags '0))
(let $3 '('StrictSchema '1))
(let $4 '('UniqueKeys '0))
(let $5 (Bool 'true))
(let $6 (DataType 'String))
(let $7 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0)))
(let $8 '('RecordsCount '3))
(let $9 '('ChunkCount '1))
(let $10 '('ModifyTime '0))
(let $11 '('Revision '0))
(let $12 '('('"_logical_id" '960) '('"_id" '"4977e78a-b78237db-f9c94d43-64740ba9") '('"_wide_channels" (StructType '('"key" $6) '('"value" $6)))))
(let $13 (DqPhyStage '() (lambda '() (block '(
  (let $22 '@@["StructType";[["key";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
  (let $23 '('"key"))
  (let $24 (YqlRowSpec $2 $3 $4 '('Type $22) '('SortDirections '($5)) '('SortMembers $23) '('SortedBy $23) '('SortedByTypes '($6))))
  (let $25 (YtStat '('Id '"SortedByKey") $8 '('DataSize '"87") $9 $10 $11))
  (let $26 (YtTable '"SortedByKey" $24 $7 $25 '() (Void) (Void) '"/Root/plato"))
  (let $27 (YtReadTable! world $1 '((YtSection '((YtPath $26 '('"key" '"value") (Void) (Void))) '()))))
  (return (FromFlow (DqReadWideWrap $27 '())))
))) $12))
(let $14 (DqCnBroadcast (TDqOutput $13 '0)))
(let $15 (StructType '('"a.key" $6) '('"a.subkey" $6) '('"a.value" $6) '('"b.key" $6) '('"b.value" $6)))
(let $16 '('('"_logical_id" '1064) '('"_id" '"431ab7e8-cb500d31-9e1755a0-ef9dc480") '('"_wide_channels" $15)))
(let $17 (DqPhyStage '($14) (lambda '($28) (block '(
  (let $29 '('Many 'Hashed 'Compact))
  (let $30 (NarrowSqueezeToDict (ToFlow $28) (lambda '($31 $32) '($31 $31)) (lambda '($33 $34) (AsStruct '('"key" $33) '('"value" $34))) $29))
  (return (FromFlow (WideSort (FlatMap $30 (lambda '($35) (block '(
    (let $36 '"SortedByKeySubkey")
    (let $37 '@@["StructType";[["key";["DataType";"String"]];["subkey";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
    (let $38 '('"key" '"subkey"))
    (let $39 (YqlRowSpec $2 $3 $4 '('Type $37) '('SortDirections '($5 $5)) '('SortMembers $38) '('SortedBy $38) '('SortedByTypes '($6 $6))))
    (let $40 (YtStat '('Id $36) $8 '('DataSize '"132") $9 $10 $11))
    (let $41 (YtTable $36 $39 $7 $40 '() (Void) (Void) '"/Root/plato"))
    (let $42 '('"key" '"subkey" '"value"))
    (let $43 (YtReadTable! world $1 '((YtSection '((YtPath $41 $42 (Void) (Void))) '()))))
    (let $44 '('0 '0 '1 '1 '2 '2))
    (let $45 '('"key" '3 '"value" '4))
    (return (MapJoinCore (DqReadWideWrap $43 '()) $35 'Inner '('0 '1) '('"key" '"key") $44 $45 '('"a.key" '"a.subkey") '('"b.key" '"b.key")))
  )))) '('('2 $5) '('4 $5)))))
))) $16))
(let $18 (DqCnMerge (TDqOutput $17 '0) '('('2 '"Asc") '('4 '"Asc"))))
(let $19 (DqPhyStage '($18) (lambda '($46) (FromFlow (NarrowMap (ToFlow $46) (lambda '($47 $48 $49 $50 $51) (AsStruct '('"a.key" $47) '('"a.subkey" $48) '('"a.value" $49) '('"b.key" $50) '('"b.value" $51)))))) '('('"_logical_id" '1076) '('"_id" '"9432b0e2-fabcd6d6-799fd6bc-a039721f"))))
(let $20 '($13 $17 $19))
(let $21 (DqCnResult (TDqOutput $19 '0) '()))
(return (KqpPhysicalQuery '((KqpPhysicalTx $20 '($21) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType $15) '0 '0)) '('('"type" '"query"))))
)
