按 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>类型的消息时，我们实际上应该做的是应用以下转换：&nbsp;beam.ParDo0(s, func(key []uint8, values func(*[]uint8) bool) {}, pcoll)&nbsp;Go 将其解释为CoGBK<[]uint8,[]uint8>.