(
(let $1 '('('"_logical_id" '1500) '('"_id" '"e9118165-1674e5e9-a3848786-472e1aaa") '('"_wide_channels" (StructType '('"UserID" (DataType 'Int64))))))
(let $2 (DqPhyStage '() (lambda '() (block '(
  (let $13 (KqpTable '"/local/test_db/olap_yatests/clickbench/hits" '"72075186224037897:8" '"" '1))
  (let $14 (KqpBlockReadOlapTableRanges $13 (Void) '('"UserID") '() '() (lambda '($16) $16)))
  (let $15 (lambda '($17 $18) (BlockAsStruct '('"UserID" $17)) $18))
  (return (FromFlow (WideCombiner (ToFlow (WideFromBlocks (FromFlow (WideMap $14 $15)))) '-1073741824 (lambda '($19) (Member $19 '"UserID")) (lambda '($20 $21) $20) (lambda '($22 $23 $24) $24) (lambda '($25 $26) $26))))
))) $1))
(let $3 (DqCnHashShuffle (TDqOutput $2 '0) '('0)))
(let $4 (Uint64 '1))
(let $5 (Bool 'false))
(let $6 (DataType 'Uint64))
(let $7 '('('"_logical_id" '2208) '('"_id" '"e5084542-b1ed58b6-db9e9fdf-b91f912e") '('"_wide_channels" (StructType '('_yql_agg_0 (OptionalType $6))))))
(let $8 (DqPhyStage '($3) (lambda '($27) (block '(
  (let $28 (lambda '($32) $32))
  (let $29 (lambda '($33 $34)))
  (let $30 (WideCombiner (ToFlow $27) '"" $28 $29 $29 $28))
  (let $31 (Condense1 (NarrowMap $30 (lambda '($35) (AsStruct '('"UserID" $35)))) (lambda '($36) $4) (lambda '($37 $38) $5) (lambda '($39 $40) (Inc $40))))
  (return (FromFlow (ExpandMap $31 (lambda '($41) (Just $41)))))
))) $7))
(let $9 (DqCnUnionAll (TDqOutput $8 '0)))
(let $10 (DqPhyStage '($9) (lambda '($42) (block '(
  (let $43 (WideCondense1 (ToFlow $42) (lambda '($45) $45) (lambda '($46 $47) $5) (lambda '($48 $49) (IfPresent $48 (lambda '($50) (IfPresent $49 (lambda '($51) (Just (AggrAdd $50 $51))) $48)) $49))))
  (let $44 (Condense (NarrowMap (Take $43 $4) (lambda '($52) (AsStruct '('Count0 (Unwrap $52))))) (Nothing (OptionalType (StructType '('Count0 $6)))) (lambda '($53 $54) $5) (lambda '($55 $56) (Just $55))))
  (return (FromFlow (Map $44 (lambda '($57) (AsStruct '('"column0" (Coalesce (Member $57 'Count0) (Uint64 '0))))))))
))) '('('"_logical_id" '2943) '('"_id" '"9d51bd8f-6142cef-1887da97-ca5acbe3"))))
(let $11 '($2 $8 $10))
(let $12 (DqCnResult (TDqOutput $10 '0) '('"column0")))
(return (KqpPhysicalQuery '((KqpPhysicalTx $11 '($12) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType (StructType '('"column0" $6))) '0 '0)) '('('"type" '"query"))))
)
