我在 Apache Beam Go SDK 中有一個管道。pcoll := beam.GroupByKey(s, src)問題是，在 GroupByKey 轉換之后，我想用 ParDo 轉換進一步處理它。我有類型的問題，因為 Go 要我定義 ParDo 函數輸入，如下所示：value CoGBK<[]uint8,[]uint8>但是 Go 中沒有類型 CoGBK。有沒有辦法在 Apache Beam Go SDK 中定義這種類型？
1 回答
肥皂起泡泡
TA貢獻1829條經驗 獲得超6個贊
好的，當我們收到需要值CoGBK<[]uint8,[]uint8>類型的消息時，我們實際上應該做的是應用以下轉換： beam.ParDo0(s, func(key []uint8, values func(*[]uint8) bool) {}, pcoll) Go 將其解釋為CoGBK<[]uint8,[]uint8>.
- 1 回答
- 0 關注
- 152 瀏覽
添加回答
舉報
0/150
提交
取消