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

今日不肯埋头，明日何以抬头！每日一句努力自己的话哈哈~哈喽，今天我将给大家带来一篇《按 Apache Beam 管道中的密钥集合类型分组》，主要内容是讲解等等，感兴趣的朋友可以收藏或者有更好的建议在评论提出，我都会认真看的！大家一起进步，一起学习！

我在 apache beam go sdk 中有一个管道。

pcoll := beam.groupbykey(s, src)

问题是，在 groupbykey 转换之后，我想使用 pardo 转换进一步处理它。我遇到了类型问题，因为 go 希望我定义 pardo 函数输入，如下所示：

value CoGBK<[]uint8,[]uint8>

但是go中没有cogbk类型。有没有办法在 apache beam go sdk 中定义此类类型？

解决方案

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

本篇关于《按 Apache Beam 管道中的密钥集合类型分组》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！