我在Apache Beam Go SDK中有一个管道。 pcoll := beam.GroupByKey(s, src) 问题是,在GroupByKey转换之后,我想用ParDo转换进一步处理它。我有类型的问题,因为Go想让我定义如下的ParDo函数输入: value CoGBK<[]uint8,[]uint8> 但是Go中没有CoGBK类型。有没有办法在Apache Beam Go SDK中定义这样的<
令人困惑的是,每个关于数据流的谷歌文档都说它现在是基于Apache光束的,并将我引导到光束网站。此外,如果我查找github项目,我会发现google dataflow项目是空的,并且所有的项目都转到apache see repo。假设我现在需要创建一个管道,根据我从Apache光束中读到的,我会这样做:from apache_beam.opti