(
(let $1 '('"UserID" (DataType 'Int64)))
(let $2 (DataType 'Uint64))
(let $3 '('('"_logical_id" '1501) '('"_id" '"48d78cf-78d0a9de-25dc5fa9-b5b1b19") '('"_wide_channels" (StructType $1 '('_yql_agg_0 $2)))))
(let $4 (DqPhyStage '() (lambda '() (block '(
  (let $13 (KqpTable '"/local/test_db/olap_yatests/clickbench/hits" '"72075186224037897:8" '"" '1))
  (let $14 '('"UserID"))
  (let $15 (KqpBlockReadOlapTableRanges $13 (Void) $14 '() '() (lambda '($17) (TKqpOlapAgg $17 '('('_yql_agg_0 '"count" '"*")) $14))))
  (let $16 (lambda '($18 $19 $20) (block '(
    (let $21 (BlockAsStruct '('"UserID" $18) '('_yql_agg_0 $19)))
    (return (BlockMember $21 '"UserID") (BlockMember $21 '_yql_agg_0) $20)
  ))))
  (return (FromFlow (WideMap $15 $16)))
))) $3))
(let $5 (DqCnHashShuffle (TDqOutput $4 '0) '('0)))
(let $6 (Uint64 '10))
(let $7 '('('"_logical_id" '1870) '('"_id" '"68a0ef9a-ee98b0d1-79f6a819-247a0b74") '('"_wide_channels" (StructType '('Count0 $2) $1))))
(let $8 (DqPhyStage '($5) (lambda '($22) (block '(
  (let $23 (lambda '($34 $35) $35 $34))
  (let $24 (WideCombiner (ToFlow (WideFromBlocks $22)) '"" (lambda '($25 $26) $25) (lambda '($27 $28 $29) $29) (lambda '($30 $31 $32 $33) (AggrAdd $32 $33)) $23))
  (return (FromFlow (WideTopSort $24 $6 '('('0 (Bool 'false))))))
))) $7))
(let $9 (DqCnMerge (TDqOutput $8 '0) '('('0 '"Desc"))))
(let $10 (DqPhyStage '($9) (lambda '($36) (FromFlow (NarrowMap (Take (ToFlow $36) $6) (lambda '($37 $38) (AsStruct '('"UserID" $38) '('"cnt" $37)))))) '('('"_logical_id" '1967) '('"_id" '"15f3b9b-ba52fee6-c0b468e8-4c6afb10"))))
(let $11 '($4 $8 $10))
(let $12 (DqCnResult (TDqOutput $10 '0) '('"UserID" '"cnt")))
(return (KqpPhysicalQuery '((KqpPhysicalTx $11 '($12) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType (StructType $1 '('"cnt" $2))) '0 '0)) '('('"type" '"query"))))
)
