Hi folks,

In Java SDK, we have robust error handling using tagged outputs and
PCollectionTuples.

Do we have something similar in Go SDK? I have been unable to locate it in
the reference docs
<https://pkg.go.dev/github.com/apache/beam/sdks/v2/go/pkg/beam>.

*A general usecase for error handling who might not be familiar with error
handling in Java SDK:*
My custom PTransform can throw error while writing to Redis and I need to
know which key-value pairs were not written in the redis. My PTransform
will also output the successfully written key-value pairs. I need a way to
somehow differentiate between successful and error outputs.

Reply via email to