(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (Configure! $1 (DataSource '"dq" '"$all") '"Attr" '"maxtasksperstage" '"2"))
(let $3 (Configure! $2 (DataSource '"pq" '"$all") '"Attr" '"consumer" '"test_client"))
(let $4 (DataSource '"pq" '"pq"))
(let $5 '"random_column_name")
(let $6 (StructType '($5 (DataType 'String))))
(let $7 (PqTopic '"pq" '"local" '"test_topic_input" '('('"PartitionsCount" '"1")) '() $6))
(let $8 '('"Endpoint" '"<pq_pq_endpoint>"))
(let $9 '('"SharedReading" '"1"))
(let $10 '('"UseSsl" '"1"))
(let $11 '('('"Consumer" '"test_client") $8 $9 '('"ReconnectPeriod" '"") '('"Format" '"raw") '('"ReadGroup" '"fqrun") $10))
(let $12 (SecureParam '"cluster:default_pq"))
(let $13 (DqPqTopicSource $3 $7 '($5) $11 $12 '"" $6 '""))
(let $14 (DataSink '"pq" '"pq"))
(let $15 (DqPqTopicSink $7 '($8 $10) $12))
(return (Commit! (DqQuery! $3 '((DqStage '((DqSource $4 $13)) (lambda '($16) (block '(
  (let $17 '('('"format" '"raw") '('"formatSettings" '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX"))) '('"settings" '($9))))
  (let $18 (DqSourceWideWrap $16 $4 $6 $17))
  (return (NarrowMap $18 (lambda '($19) (AsStruct '($5 $19)))))
))) '('('"_logical_id" '0)) '((DqSink '"0" $14 $15))))) $14))
)
