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