(
(let $1 (Configure! world (DataSource '"config") '"DqEngine" '"force"))
(let $2 (Configure! $1 (DataSource '"dq" '"$all") '"Attr" '"watermarksmode" '"default"))
(let $3 (Configure! $2 (DataSource '"pq" '"$all") '"Attr" '"consumer" '"test_client"))
(let $4 (DataSink 'result))
(let $5 '('('"system" '"_yql_sys_seq_no") '('"system" '"_yql_sys_partition_id") '('"system" '"_yql_sys_create_time") '('"system" '"_yql_sys_message_group_id") '('"system" '"_yql_sys_tsp_write_time") '('"system" '"_yql_sys_offset")))
(let $6 (PqTopic '"pq" '"local" '"test_topic_input" '('('"PartitionsCount" '"1")) $5 (StructType '('"ts" (DataType 'Timestamp)))))
(let $7 (Right! (PqReadTopic! $3 (DataSource '"pq" '"pq") $6 '('"ts") '"json_each_row" '"" (Void) '('('"data.datetime.formatname" '"POSIX") '('"data.timestamp.formatname" '"POSIX")) (lambda '($9) (Unwrap (-MayWarn (SqlPlainColumnOrType $9 '"timestamp") (Interval '"5000000")))))))
(let $8 (ResWrite! $3 $4 (Key) (RemovePrefixMembers (RemoveSystemMembers (PersistableRepr (SqlProject $7 '((SqlProjectStarItem (TypeOf $7) '"" (lambda '($10) $10) '()))))) '('_yql_sys_)) '('('type) '('autoref))))
(return (Commit! (Commit! $8 $4) (DataSink '"pq" '"pq")))
)
