Re: How to handle errors in GO SDK in a custom PTransform

Thanks, Danny! This was what I was looking for. On Wed, 5 Apr 2023 at 18:40, Danny McCormick via user wrote: > The Go SDK doesn't use tagged outputs, instead it uses positional ordering > for emitting multiple outputs. So you can do something like: > > func processElements(element string, goodEm

Re: How to handle errors in GO SDK in a custom PTransform

The Go SDK doesn't use tagged outputs, instead it uses positional ordering for emitting multiple outputs. So you can do something like: func processElements(element string, goodEmit, errEmit func(string)) { if element.isGood { goodEmit(element) } else { errEmit(element) } } w

How to handle errors in GO SDK in a custom PTransform

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 . *A general usecase for error handling wh