(
(let $1 (DataSource '"yt" '"/Root/plato"))
(let $2 '@@["StructType";[["key";["DataType";"String"]];["subkey";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
(let $3 (Bool 'true))
(let $4 '('"key" '"subkey"))
(let $5 (DataType 'String))
(let $6 (YqlRowSpec '('NativeYtTypeFlags '0) '('StrictSchema '1) '('UniqueKeys '0) '('Type $2) '('SortDirections '($3 $3)) '('SortMembers $4) '('SortedBy $4) '('SortedByTypes '($5 $5))))
(let $7 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0) '('HasRLS '0) '('Attrs '('('"native_strict_schema" '"false")))))
(let $8 (YtStat '('Id '"Input") '('RecordsCount '"4") '('DataSize '"168") '('ChunkCount '1) '('ModifyTime '0) '('Revision '0)))
(let $9 (YtTable '"Input" $6 $7 $8 '() (Void) (Void) '"/Root/plato"))
(let $10 '('"subkey"))
(let $11 '('('"unordered")))
(let $12 (DqPhyStage '() (lambda '() (block '(
  (let $40 (YtReadTable! world $1 '((YtSection '((YtPath $9 $10 (Void) (Void) (Void))) $11))))
  (return (FromFlow (NarrowMap (WideFilter (DqReadWideWrap $40 '()) (lambda '($41) (< $41 (String '"100")))) (lambda '($42) (AsStruct '('"subkey" $42))))))
))) '('('"_logical_id" '2320) '('"_id" '"b0dc82bf-6b55aaa7-c044b885-6247c5a0"))))
(let $13 (DqCnUnionAll (TDqOutput $12 '0)))
(let $14 (DqPhyStage '($13) (lambda '($43) $43) '('('"_logical_id" '2548) '('"_id" '"42709a75-c5e33730-963a2247-55880328"))))
(let $15 (DqCnResult (TDqOutput $14 '0) $10))
(let $16 '('('"type" '"generic")))
(let $17 (KqpPhysicalTx '($12 $14) '($15) '() $16))
(let $18 '('"value"))
(let $19 (DqPhyStage '() (lambda '() (block '(
  (let $44 (YtReadTable! world $1 '((YtSection '((YtPath $9 $18 '((YtRowRange (Void) (Uint64 '3))) (Void) (Void))) '()))))
  (return (FromFlow (NarrowMap (DqReadWideWrap $44 '()) (lambda '($45) (AsStruct '('"value" $45))))))
))) '('('"_logical_id" '2373) '('"_id" '"abdcb6a6-87f0b922-a4e3af02-e5e4dad5"))))
(let $20 (DqCnUnionAll (TDqOutput $19 '0)))
(let $21 (DqPhyStage '($20) (lambda '($46) $46) '('('"_logical_id" '2718) '('"_id" '"1b87136c-5959a471-1769b7e3-69aad22a"))))
(let $22 (DqCnResult (TDqOutput $21 '0) $18))
(let $23 (KqpPhysicalTx '($19 $21) '($22) '() $16))
(let $24 (lambda '($50 $51) (AsStruct '('_yql_sys_order_by (Minus (SafeCast $51 (OptionalType (DataType 'Int32))))) '('"key" $50) '('"subkey" $51))))
(let $25 (Uint64 '5))
(let $26 (lambda '($52) (Member $52 '_yql_sys_order_by)))
(let $27 '('"key" $5))
(let $28 '('"subkey" $5))
(let $29 '('('"_logical_id" '2447) '('"_id" '"a6093bcb-4b11ee6c-c80a9263-7e8015eb") '('"_wide_channels" (StructType $27 $28))))
(let $30 (DqPhyStage '() (lambda '() (block '(
  (let $47 (YtReadTable! world $1 '((YtSection '((YtPath $9 $4 (Void) (Void) (Void))) $11))))
  (let $48 (Top (NarrowMap (DqReadWideWrap $47 '()) $24) $25 $3 $26))
  (let $49 (lambda '($53) (Member $53 '"key") (Member $53 '"subkey")))
  (return (FromFlow (ExpandMap $48 $49)))
))) $29))
(let $31 (DqCnUnionAll (TDqOutput $30 '0)))
(let $32 (DqPhyStage '($31) (lambda '($54) (block '(
  (let $55 (TopSort (NarrowMap (ToFlow $54) $24) $25 $3 $26))
  (return (FromFlow (Map $55 (lambda '($56) (AsStruct '('"key" (Member $56 '"key")))))))
))) '('('"_logical_id" '2510) '('"_id" '"d05fc192-9f419deb-1d542490-9046658a"))))
(let $33 (DqCnResult (TDqOutput $32 '0) '('"key")))
(let $34 (KqpPhysicalTx '($30 $32) '($33) '() $16))
(let $35 '($17 $23 $34))
(let $36 (KqpTxResultBinding (ListType (StructType $28)) '0 '0))
(let $37 (KqpTxResultBinding (ListType (StructType '('"value" $5))) '1 '0))
(let $38 (KqpTxResultBinding (ListType (StructType $27)) '"2" '0))
(let $39 '($36 $37 $38))
(return (KqpPhysicalQuery $35 $39 '('('"type" '"query"))))
)
