lalitx17 opened a new pull request, #38985:
URL: https://github.com/apache/beam/pull/38985
Adds `publish_time_field` support to the Beam YAML `ReadFromPubSub`
transform.
When configured, `ReadFromPubSub` exposes the Pub/Sub message `publish_time`
as a field on the output `Row`, allowing downstream transforms and sinks such
as BigQuery to store or inspect the original Pub/Sub publish time.
```yaml
type: ReadFromPubSub
config:
topic: ...........
format: RAW
publish_time_field: pubsub_publish_time
```
addresses #35127
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
