Apache光束管道中的Group by键集合类型
Apache光束管道中的Group by键集合类型
提问于 2020-11-06 19:38:05
我在Apache Beam Go SDK中有一个管道。
pcoll := beam.GroupByKey(s, src)问题是，在GroupByKey转换之后，我想用ParDo转换进一步处理它。我有类型的问题，因为Go想让我定义如下的ParDo函数输入：
value CoGBK<[]uint8,[]uint8>但是Go中没有CoGBK类型。有没有办法在Apache Beam Go SDK中定义这样的类型？
回答 1
Stack Overflow用户
回答已采纳
发布于 2020-11-09 19:19:49
好的，当我们收到一条消息说我们需要CoGBK<[]uint8,[]uint8>类型的值时，我们实际应该做的是应用下面的转换：beam.ParDo0(s, func(key []uint8, values func(*[]uint8) bool) {}, pcoll)，Go将其解释为CoGBK<[]uint8,[]uint8>。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/64713935
复制相关文章
相似问题
腾讯云开发者
