如何将 ParDo 应用于 PDone 对象

Question

我的流水线有以下 2 个步骤。

1. 从 BigQuery 中提取数据，然后将其转换并存储在 CloudStorage 中。
2. 从CloudStorage中提取数据，然后转换并存储在S3中。

在step1之后，我可以得到PDone对象，但是它没有apply或者read方法。 有没有办法在步骤 1 过程之后附加步骤 2 过程？

Answer 1

您可以将BigQuery提取的数据同时写入多个地方。例如。参见 。