(
(let $1 (DataType 'String))
(let $2 (ListType (StructType '('"column0" $1) '('"subkey" $1) '('"value" $1))))
(let $3 '('('"_logical_id" '547) '('"_id" '"e5fe6553-407bac9d-b537c012-51403797") '('"_partition_mode" '"single")))
(let $4 (DqPhyStage '() (lambda '() (Iterator (List $2))) $3))
(let $5 '('"column0" '"subkey" '"value"))
(let $6 (DqCnResult (TDqOutput $4 '"0") $5))
(return (KqpPhysicalQuery '((KqpPhysicalTx '($4) '($6) '() '('('"type" '"generic")))) '((KqpTxResultBinding $2 '"0" '"0")) '('('"type" '"query"))))
)
