Typically you would apply your first ParDo getting back a PCollection and
then apply your second ParDo to the return PCollection. You can get a lot
more details in the programming guide[1].
For example:
PCollection<T> input = ...
input.apply("ParDo1", ParDo.of(myDoFn1)).apply("ParDo2", ParDo.of(myDoFn2));
In Python it would be
input = ...
input | "ParDo1" >> beam.ParDo(myDoFn1) | "ParDo2" >> beam.ParDo(myDoFn2)
1:
https://beam.apache.org/documentation/programming-guide/#applying-transforms
On Mon, Jun 17, 2019 at 3:18 PM Anjana Pydi <anjan...@bahwancybertek.com>
wrote:
> Hi,
>
> I want to do following steps:
>
> 1. For a list of ids, Do a Get request on an API which will give back a
> list of dictionaries as response. [ParDo1]
> 2. For each of dictionary obtained in Step1 , make some changes and post
> as JSON to API endpoint. [ParDo2]
>
> Step1 is working but not sure how to use second ParDo. Please let me know
> your suggestions.
>
> Thanks,
> Anjana
> -----------------------------------------------------------------------------------------------------------------------
> The information contained in this communication is intended solely for the
> use of the individual or entity to whom it is addressed and others
> authorized to receive it. It may contain confidential or legally privileged
> information. If you are not the intended recipient you are hereby notified
> that any disclosure, copying, distribution or taking any action in reliance
> on the contents of this information is strictly prohibited and may be
> unlawful. If you are not the intended recipient, please notify us
> immediately by responding to this email and then delete it from your
> system. Bahwan Cybertek is neither liable for the proper and complete
> transmission of the information contained in this communication nor for any
> delay in its receipt.
>
