按 Apache Beam 管道中的键集合类型分组

Question

我在 Apache Beam Go SDK 中有一个管道。pcoll := beam.GroupByKey(s, src)问题是，在 GroupByKey 转换之后，我想用 ParDo 转换进一步处理它。我有类型的问题，因为 Go 要我定义 ParDo 函数输入，如下所示：value CoGBK<[]uint8,[]uint8>但是 Go 中没有类型 CoGBK。有没有办法在 Apache Beam Go SDK 中定义这种类型？

Answer 1

好的，当我们收到需要值CoGBK<[]uint8,[]uint8>类型的消息时，我们实际上应该做的是应用以下转换： beam.ParDo0(s, func(key []uint8, values func(*[]uint8) bool) {}, pcoll) Go 将其解释为CoGBK<[]uint8,[]uint8>.