【发布时间】:2021-09-22 19:39:02
【问题描述】:
我正在尝试在我的管道中实现复合 PTransform。我有一个主输入 PCollection 和一个附加 PCollection,我需要将它们传递给我的 PTransform,以便它可以在我的复合变换 ParDo 中用作辅助输入。是否可以通过复合 PTransform 构造函数,还是我需要在这里使用不同的方法?
【问题讨论】:
标签: apache-beam
我正在尝试在我的管道中实现复合 PTransform。我有一个主输入 PCollection 和一个附加 PCollection,我需要将它们传递给我的 PTransform,以便它可以在我的复合变换 ParDo 中用作辅助输入。是否可以通过复合 PTransform 构造函数,还是我需要在这里使用不同的方法?
【问题讨论】:
标签: apache-beam
您可以通过构造函数传递 PCollectionView。例如:Access elements of PCollectionView<List<Foo>> : Google Cloud Dataflow/Apache Beam
【讨论】: