提问者:小点点

如何将ParDo应用于PDone对象


我的管道有以下2个步骤。

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

step1之后,我可以获取PDone对象,但它没有应用或读取方法。有什么方法可以在step1过程之后附加步骤2过程吗?


共1个答案

匿名用户

您可以将从BigQuery中提取的数据同时写入多个位置。例如。看到这个答案。