(
(let $1 (Bool 'true))
(let $2 (DataType 'String))
(let $3 (StructType '('"key" $2) '('"subkey" $2) '('"value" $2)))
(let $4 (DqPhyStage '() (lambda '() (block '(
  (let $15 '@@["StructType";[["key";["DataType";"String"]];["subkey";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
  (let $16 '($1 $1 $1))
  (let $17 '('"key" '"subkey" '"value"))
  (let $18 '($2 $2 $2))
  (let $19 (YqlRowSpec '('NativeYtTypeFlags '0) '('StrictSchema '1) '('UniqueKeys '0) '('Type $15) '('SortDirections $16) '('SortMembers $17) '('SortedBy $17) '('SortedByTypes $18)))
  (let $20 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0) '('HasRLS '0) '('Attrs '('('"native_strict_schema" '"false")))))
  (let $21 (YtStat '('Id '"Input") '('RecordsCount '"6") '('DataSize '"252") '('ChunkCount '1) '('ModifyTime '0) '('Revision '0)))
  (let $22 (YtTable '"Input" $19 $20 $21 '() (Void) (Void) '"/Root/plato"))
  (let $23 (YtReadTable! world (DataSource '"yt" '"/Root/plato") '((YtSection '((YtPath $22 $17 (Void) (Void) (Void))) '('('"unordered"))))))
  (return (FromFlow (NarrowFlatMap (DqReadWideWrap $23 '()) (lambda '($24 $25 $26) (block '(
    (let $27 (String '"037"))
    (let $28 (>= $24 $27))
    (let $29 (<= $24 $27))
    (let $30 (And $28 $29))
    (let $31 (AsStruct '('"key" $24) '('"subkey" $25) '('"value" $26)))
    (let $32 (VariantType (TupleType $3 $3 $3)))
    (let $33 (List (ListType $32)))
    (let $34 (If $30 (AsList (Variant $31 '0 $32)) $33))
    (let $35 (If (And $29 $28) (AsList (Variant $31 '1 $32)) $33))
    (let $36 (If $30 (AsList (Variant $31 '2 $32)) $33))
    (return (Extend $34 $35 $36))
  ))))))
))) '('('"_logical_id" '2740) '('"_id" '"62c54b55-ab37e987-3a17b352-4b931f1d"))))
(let $5 (DqCnParallelUnionAll (TDqOutput $4 '1)))
(let $6 (DqCnParallelUnionAll (TDqOutput $4 '0)))
(let $7 (DqCnParallelUnionAll (TDqOutput $4 '2)))
(let $8 '($5 $6 $7))
(let $9 '('('"_logical_id" '2691) '('"_id" '"5ac90026-1ce8c49f-a5c94228-19ad87f5") '('"_wide_channels" $3)))
(let $10 (DqPhyStage $8 (lambda '($37 $38 $39) (block '(
  (let $40 (Extend (ToFlow $37) (ToFlow $38) (ToFlow $39)))
  (let $41 (Sort $40 '($1 $1) (lambda '($43) '((Member $43 '"key") (Member $43 '"subkey")))))
  (let $42 (lambda '($44) (Member $44 '"key") (Member $44 '"subkey") (Member $44 '"value")))
  (return (FromFlow (ExpandMap $41 $42)))
))) $9))
(let $11 (DqCnMerge (TDqOutput $10 '0) '('('0 '"Asc") '('1 '"Asc"))))
(let $12 (DqPhyStage '($11) (lambda '($45) (FromFlow (NarrowMap (ToFlow $45) (lambda '($46 $47 $48) (AsStruct '('"key" $46) '('"subkey" $47) '('"value" $48)))))) '('('"_logical_id" '2703) '('"_id" '"4cf56430-d4009878-d9bedc83-c659b5a6"))))
(let $13 '($4 $10 $12))
(let $14 (DqCnResult (TDqOutput $12 '0) '()))
(return (KqpPhysicalQuery '((KqpPhysicalTx $13 '($14) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType $3) '0 '0)) '('('"type" '"query"))))
)
