(
(let $1 '('0 '1 '2))
(let $2 '('"MobilePhone" (DataType 'Int16)))
(let $3 '('"MobilePhoneModel" (DataType 'Utf8)))
(let $4 (DataType 'Int64))
(let $5 (StructType $2 $3 '('"UserID" $4)))
(let $6 '('('"_logical_id" '2145) '('"_id" '"af6847f-59aff3d4-fb94632a-f9e6cf8b") '('"_wide_channels" $5)))
(let $7 (DqPhyStage '() (lambda '() (block '(
  (let $24 (KqpTable '"/local/test_db/olap_yatests/clickbench/hits" '"72075186224037897:8" '"" '1))
  (let $25 '('"MobilePhone" '"MobilePhoneModel" '"UserID"))
  (let $26 (KqpBlockReadOlapTableRanges $24 (Void) $25 '() '() (lambda '($27) (block '(
    (let $28 '('neq '"MobilePhoneModel" (String '"")))
    (return (KqpOlapFilter $27 $28))
  )))))
  (return (BlockCombineHashed (FromFlow $26) (Void) $1 '()))
))) $6))
(let $8 (DqCnHashShuffle (TDqOutput $7 '0) $1 '0 '"HashV1"))
(let $9 '('0 '1))
(let $10 (DataType 'Uint64))
(let $11 (StructType $2 $3 '('_yql_agg_0 (OptionalType $10)) '('"_yql_group_stream_index" (DataType 'Uint32))))
(let $12 '('('"_logical_id" '3005) '('"_id" '"2de19fa7-e294749f-5b44ed7a-819c32f8") '('"_wide_channels" $11)))
(let $13 (DqPhyStage '($8) (lambda '($29) (block '(
  (let $30 (BlockMergeFinalizeHashed $29 $1 '()))
  (let $31 (lambda '($32 $33 $34) $32 $33 (Just $34) (Uint32 '0)))
  (return (FromFlow (WideMap (ToFlow (WideFromBlocks (BlockCombineHashed $30 (Void) $9 '('((AggBlockApply 'count $4) '2))))) $31)))
))) $12))
(let $14 (DqCnHashShuffle (TDqOutput $13 '0) $9 '0 '"HashV1"))
(let $15 (Uint64 '10))
(let $16 (StructType '('Count0 $10) $2 $3))
(let $17 '('('"_logical_id" '3528) '('"_id" '"fe3f1d4b-a6ee5894-91d0eba6-a1958fa7") '('"_wide_channels" $16)))
(let $18 (DqPhyStage '($14) (lambda '($35) (block '(
  (let $36 (lambda '($40 $41 $42 $43) $40 $41 $43 $42))
  (let $37 (AggBlockApplyState 'count $10 $10))
  (let $38 (WideTopSort (ToFlow (WideFromBlocks (BlockMergeManyFinalizeHashed (WideToBlocks (FromFlow (WideMap (ToFlow $35) $36))) $9 '('($37 '"3")) '2 '('('0))))) $15 '('('2 (Bool 'false)))))
  (let $39 (lambda '($44 $45 $46) $46 $44 $45))
  (return (FromFlow (WideMap $38 $39)))
))) $17))
(let $19 (DqCnMerge (TDqOutput $18 '0) '('('0 '"Desc"))))
(let $20 (DqPhyStage '($19) (lambda '($47) (FromFlow (NarrowMap (Take (ToFlow $47) $15) (lambda '($48 $49 $50) (AsStruct '('"MobilePhone" $49) '('"MobilePhoneModel" $50) '('"u" $48)))))) '('('"_logical_id" '3650) '('"_id" '"5c56fdf9-2690e8ab-e4ec0123-92f8e889"))))
(let $21 '($7 $13 $18 $20))
(let $22 '('"MobilePhone" '"MobilePhoneModel" '"u"))
(let $23 (DqCnResult (TDqOutput $20 '0) $22))
(return (KqpPhysicalQuery '((KqpPhysicalTx $21 '($23) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType (StructType $2 $3 '('"u" $10))) '0 '0)) '('('"type" '"query"))))
)
