(
(let $1 '('"SearchPhrase" (DataType 'Utf8)))
(let $2 '('"UserID" (DataType 'Int64)))
(let $3 (DataType 'Uint64))
(let $4 (StructType $1 $2 '('_yql_agg_0 $3)))
(let $5 '('('"_logical_id" '1515) '('"_id" '"95b71e43-d5f911b8-7e197763-73299c11") '('"_wide_channels" $4)))
(let $6 (DqPhyStage '() (lambda '() (block '(
  (let $18 (KqpTable '"/local/test_db/olap_yatests/clickbench/hits" '"72075186224037897:8" '"" '1))
  (let $19 '('"SearchPhrase" '"UserID"))
  (let $20 (KqpBlockReadOlapTableRanges $18 (Void) $19 '() '() (lambda '($21) (TKqpOlapAgg $21 '('('_yql_agg_0 '"count" '"*")) $19))))
  (return (FromFlow $20))
))) $5))
(let $7 '('0 '1))
(let $8 (DqCnHashShuffle (TDqOutput $6 '0) $7 '0 '"HashV1"))
(let $9 (Uint64 '10))
(let $10 (StructType '('Count0 $3) $1 $2))
(let $11 '('('"_logical_id" '1984) '('"_id" '"3bd2cf96-deac8c1e-cbb3a079-899a0c17") '('"_wide_channels" $10)))
(let $12 (DqPhyStage '($8) (lambda '($22) (block '(
  (let $23 (AggBlockApplyState '"count_all" $3 $3))
  (let $24 (lambda '($25 $26 $27) $27 $25 $26))
  (return (FromFlow (WideMap (Take (ToFlow (WideFromBlocks (BlockMergeFinalizeHashed $22 $7 '('($23 '"2"))))) $9) $24)))
))) $11))
(let $13 (DqCnUnionAll (TDqOutput $12 '0)))
(let $14 (DqPhyStage '($13) (lambda '($28) (FromFlow (NarrowMap (Take (ToFlow $28) $9) (lambda '($29 $30 $31) (AsStruct '('"SearchPhrase" $30) '('"UserID" $31) '('"column2" $29)))))) '('('"_logical_id" '2088) '('"_id" '"3337a438-2cd64fbc-46be4659-9de80d09"))))
(let $15 '($6 $12 $14))
(let $16 '('"UserID" '"SearchPhrase" '"column2"))
(let $17 (DqCnResult (TDqOutput $14 '0) $16))
(return (KqpPhysicalQuery '((KqpPhysicalTx $15 '($17) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType (StructType $1 $2 '('"column2" $3))) '0 '0)) '('('"type" '"query"))))
)
