(
(let $1 (DataType 'String))
(let $2 (StructType '('"key" $1) '('"subkey" $1) '('"value" $1)))
(let $3 '('('"_logical_id" '1815) '('"_id" '"f64dee3e-79d02475-bb35f0c0-d677d743") '('"_wide_channels" $2)))
(let $4 (DqPhyStage '() (lambda '() (block '(
  (let $8 (AssumeSorted (EmptyIterator (FlowType $2)) (Bool 'true) (lambda '($10) (Member $10 '"key"))))
  (let $9 (lambda '($11) (Member $11 '"key") (Member $11 '"subkey") (Member $11 '"value")))
  (return (FromFlow (ExpandMap $8 $9)))
))) $3))
(let $5 (DqCnMerge (TDqOutput $4 '0) '('('0 '"Asc"))))
(let $6 (DqPhyStage '($5) (lambda '($12) (FromFlow (NarrowMap (ToFlow $12) (lambda '($13 $14 $15) (AsStruct '('"key" $13) '('"subkey" $14) '('"value" $15)))))) '('('"_logical_id" '1827) '('"_id" '"65759542-90a4877a-b08dfd47-feb3e40"))))
(let $7 (DqCnResult (TDqOutput $6 '0) '()))
(return (KqpPhysicalQuery '((KqpPhysicalTx '($4 $6) '($7) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType $2) '0 '0)) '('('"type" '"query"))))
)
