AFAICT like most triggers, there are no implementations of them in Go. Triggers are handled by the runner in response to the configuration provided by the user at pipeline construction time.
I'm assuming you're referring to the Protocol Buffer message though, defined here: https://github.com/apache/beam/blob/5afe6772f8e2e7332d90f51fee1ab91fffd16f91/model/pipeline/src/main/proto/beam_runner_api.proto#L1291 And its generated Go version here: https://github.com/apache/beam/blob/5afe6772f8e2e7332d90f51fee1ab91fffd16f91/sdks/go/pkg/beam/model/pipeline_v1/beam_runner_api.pb.go#L4082 I'm not sure why it doesn't show up in search though. Github search is either giving up because it's 4k lines in, or it recognized it as a generated Go protobuf file. Is that what you're looking for? If you did find other Go implementations of that, or uses of it in the SDK, please link them here. I'm not aware of any. On Thu, Mar 18, 2021, 4:30 PM César Cueva Orozco <cesar.cu...@wizeline.com> wrote: > Hi Team, > > We are analyzing the AfterProcessingTime trigger functionality, and we > found that the TimestampTransform attribute is implemented in several > methods, so we want to know if there is any other implementation of > TimestampTransform in Go. > > Thank you, > -Cesar Cueva > > > > > > > > > *This email and its contents (including any attachments) are being sent > toyou on the condition of confidentiality and may be protected by > legalprivilege. Access to this email by anyone other than the intended > recipientis unauthorized. If you are not the intended recipient, please > immediatelynotify the sender by replying to this message and delete the > materialimmediately from your system. Any further use, dissemination, > distributionor reproduction of this email is strictly prohibited. Further, > norepresentation is made with respect to any content contained in this > email.*
