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