具有多个输入的 ParDo 函数

Question

我想使用适用于 Apache Beam 的 Go SDK，我正在尝试创建一个计算两个向量的点积的管道。

Computesit(a, b []int)int {
return a.Dot(b)
}
A:= beam.Create(s, []int{1,2})
B:= beam.Create(s, []int{3,4})
Dot := beam.ParDo(s,Computesit, A, B)

但我收到以下错误

Cannot use B (type.PCollection) as type beam.Option in argument to beam.ParDo

我的问题是，如果有可能，我们如何向 ParDo 函数发出多个输入呢？ 谢谢。

Answer 1

您可以使用侧输入来提供额外的 PCollection 作为输入。请参阅example。

有一个类似的问题Go SDK Apache Beam : singleton side input Singleton for int ill-defined，其中包含更多示例代码。