(
(let $1 '('0 '1))
(let $2 '('"SearchPhrase" (DataType 'Utf8)))
(let $3 (DataType 'Int64))
(let $4 '('('"_logical_id" '2047) '('"_id" '"16abd3e3-93972e34-c28f2757-8123cf62") '('"_wide_channels" (StructType $2 '('"UserID" $3)))))
(let $5 (DqPhyStage '() (lambda '() (block '(
  (let $20 (KqpTable '"/local/test_db/olap_yatests/clickbench/hits" '"72075186224037897:8" '"" '1))
  (let $21 (KqpBlockReadOlapTableRanges $20 (Void) '('"SearchPhrase" '"UserID") '() '() (lambda '($22) (block '(
    (let $23 '('neq '"SearchPhrase" (String '"")))
    (return (KqpOlapFilter $22 $23))
  )))))
  (return (BlockCombineHashed (FromFlow $21) (Void) $1 '()))
))) $4))
(let $6 (DqCnHashShuffle (TDqOutput $5 '0) $1 '0 '"HashV1"))
(let $7 '('0))
(let $8 (DataType 'Uint64))
(let $9 (StructType $2 '('_yql_agg_0 (OptionalType $8)) '('"_yql_group_stream_index" (DataType 'Uint32))))
(let $10 '('('"_logical_id" '2857) '('"_id" '"2902a740-e7057c0b-7f801e02-c31d83c7") '('"_wide_channels" $9)))
(let $11 (DqPhyStage '($6) (lambda '($24) (block '(
  (let $25 (BlockMergeFinalizeHashed $24 $1 '()))
  (let $26 (lambda '($27 $28) $27 (Just $28) (Uint32 '0)))
  (return (FromFlow (WideMap (ToFlow (WideFromBlocks (BlockCombineHashed $25 (Void) $7 '('((AggBlockApply 'count $3) '1))))) $26)))
))) $10))
(let $12 (DqCnHashShuffle (TDqOutput $11 '0) $7 '0 '"HashV1"))
(let $13 (Uint64 '10))
(let $14 '('('"_logical_id" '3354) '('"_id" '"29087e22-bcb2c1fe-a283194e-e0e5ce18") '('"_wide_channels" (StructType '('Count0 $8) $2))))
(let $15 (DqPhyStage '($12) (lambda '($29) (block '(
  (let $30 (lambda '($34 $35 $36) $34 $36 $35))
  (let $31 (AggBlockApplyState 'count $8 $8))
  (let $32 (WideTopSort (ToFlow (WideFromBlocks (BlockMergeManyFinalizeHashed (WideToBlocks (FromFlow (WideMap (ToFlow $29) $30))) $7 '('($31 '"2")) '1 '($7)))) $13 '('('1 (Bool 'false)))))
  (let $33 (lambda '($37 $38) $38 $37))
  (return (FromFlow (WideMap $32 $33)))
))) $14))
(let $16 (DqCnMerge (TDqOutput $15 '0) '('('0 '"Desc"))))
(let $17 (DqPhyStage '($16) (lambda '($39) (FromFlow (NarrowMap (Take (ToFlow $39) $13) (lambda '($40 $41) (AsStruct '('"SearchPhrase" $41) '('"u" $40)))))) '('('"_logical_id" '3472) '('"_id" '"3eb16f6d-7ee7c8f0-91f52fd5-d99e7e7e"))))
(let $18 '($5 $11 $15 $17))
(let $19 (DqCnResult (TDqOutput $17 '0) '('"SearchPhrase" '"u")))
(return (KqpPhysicalQuery '((KqpPhysicalTx $18 '($19) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType (StructType $2 '('"u" $8))) '0 '0)) '('('"type" '"query"))))
)
