(
(let $1 '"_yql_key_selector_0")
(let $2 (DataType 'String))
(let $3 '('"key" (ListType $2)))
(let $4 (StructType '($1 $2) $3 '('"value" $2)))
(let $5 '('('"_logical_id" '1844) '('"_id" '"71a9bb0d-f188178-7089409c-5c3b93c7") '('"_wide_channels" $4)))
(let $6 (DqPhyStage '() (lambda '() (block '(
  (let $16 '@@["StructType";[["key";["DataType";"String"]];["subkey";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
  (let $17 (YqlRowSpec '('NativeYtTypeFlags '0) '('StrictSchema '1) '('UniqueKeys '0) '('Type $16)))
  (let $18 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0) '('Attrs '('('"native_strict_schema" '"false")))))
  (let $19 (YtStat '('Id '"Input") '('RecordsCount '"4") '('DataSize '"166") '('ChunkCount '1) '('ModifyTime '0) '('Revision '0)))
  (let $20 (YtTable '"Input" $17 $18 $19 '() (Void) (Void) '"/Root/plato"))
  (let $21 (YtReadTable! world (DataSource '"yt" '"/Root/plato") '((YtSection '((YtPath $20 '('"key" '"value") (Void) (Void))) '()))))
  (let $22 (lambda '($23 $24) (block '(
    (let $25 (AsList $23))
    (return (StablePickle $25) $25 $24)
  ))))
  (return (FromFlow (WideMap (DqReadWideWrap $21 '()) $22)))
))) $5))
(let $7 (DqCnHashShuffle (TDqOutput $6 '0) '('0) '0 '"HashV2"))
(let $8 (Bool 'true))
(let $9 (StructType '('"column1" (DataType 'Uint64)) $3))
(let $10 '('('"_logical_id" '2552) '('"_id" '"17936d72-7a7a1ced-2931ad5c-3a6e0cc2") '('"_wide_channels" $9)))
(let $11 (DqPhyStage '($7) (lambda '($26) (block '(
  (let $27 (NarrowSqueezeToDict (ToFlow $26) (lambda '($30 $31 $32) $30) (lambda '($33 $34 $35) (AsStruct '($1 $33) '('"key" $34) '('"value" $35))) '('Auto 'Many)))
  (let $28 (Chopper (Map (OrderedFlatMap $27 (lambda '($36) (OrderedFlatMap (DictPayloads $36) (lambda '($37) (Sort $37 $8 (lambda '($38) (Member $38 '"value"))))))) (lambda '($39) (AsStruct '('"key" (Member $39 '"key")) '('"value" (Member $39 '"value"))))) (lambda '($40) (StablePickle (Member $40 '"key"))) (lambda '($41 $42) (AggrNotEquals $41 (StablePickle (Member $42 '"key")))) (lambda '($43 $44) (block '(
    (let $45 (Chain1Map $44 (lambda '($46) (block '(
      (let $47 '('_yql_RowNumber0 (Uint64 '1)))
      (let $48 (AsStruct $47 '('"key" (Member $46 '"key")) '('"value" (Member $46 '"value"))))
      (return '($48 (AsStruct $47)))
    ))) (lambda '($49 $50) (block '(
      (let $51 '('_yql_RowNumber0 (Inc (Member (Nth $50 '1) '_yql_RowNumber0))))
      (let $52 (AsStruct $51 '('"key" (Member $49 '"key")) '('"value" (Member $49 '"value"))))
      (return '($52 (AsStruct $51)))
    )))))
    (return (OrderedMap $45 (lambda '($53) (block '(
      (let $54 (Nth $53 '0))
      (return (AsStruct '('_yql_RowNumber0 (Member $54 '_yql_RowNumber0)) '('"key" (Member $54 '"key"))))
    )))))
  )))))
  (let $29 (lambda '($55) (Member $55 '_yql_RowNumber0) (Member $55 '"key")))
  (return (FromFlow (ExpandMap $28 $29)))
))) $10))
(let $12 (DqCnUnionAll (TDqOutput $11 '0)))
(let $13 (DqPhyStage '($12) (lambda '($56) (FromFlow (NarrowMap (WideSort (ToFlow $56) '('('1 $8))) (lambda '($57 $58) (AsStruct '('"column1" $57) '('"key" $58)))))) '('('"_logical_id" '2590) '('"_id" '"7b9d707c-cdbce663-48906997-d47027ad"))))
(let $14 '($6 $11 $13))
(let $15 (DqCnResult (TDqOutput $13 '0) '('"key" '"column1")))
(return (KqpPhysicalQuery '((KqpPhysicalTx $14 '($15) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType $9) '0 '0)) '('('"type" '"query"))))
)
