Apache Beam-Go SDK的API调用的批处理元素？

I'm building a Beam pipeline with the Go SDK.

I have to do some data enrichment by calling a ML model somewhere on the Cloud.

As I am processing a lot of elements, I can't just make an API call for each element, this will introduce a huge latency. I need to send a batch of elements.

I know in python there is a BatchElements() PTransform, how to make something similar in Go?

There is no such transform that is part of the Beam Go SDK at this time.

You would need to translate the GroupIntoBatches [1, 2] implementation into Go code. This would be a valuable contribution to Apache Beam so please contribute it if you do this.